@Metadata(label="eip,routing,resequence") public class StreamResequencerConfig extends ResequencerConfig
| Constructor and Description |
|---|
StreamResequencerConfig()
Creates a new
StreamResequencerConfig instance using default
values for capacity (1000) and timeout
(1000L). |
StreamResequencerConfig(int capacity,
long timeout)
|
StreamResequencerConfig(int capacity,
long timeout,
Boolean rejectOld)
|
StreamResequencerConfig(int capacity,
long timeout,
Boolean rejectOld,
ExpressionResultComparator comparator)
|
StreamResequencerConfig(int capacity,
long timeout,
ExpressionResultComparator comparator)
|
| Modifier and Type | Method and Description |
|---|---|
int |
getCapacity() |
ExpressionResultComparator |
getComparator() |
String |
getComparatorRef() |
static StreamResequencerConfig |
getDefault()
Returns a new
StreamResequencerConfig instance using default
values for capacity (1000) and timeout
(1000L). |
Boolean |
getIgnoreInvalidExchanges() |
Boolean |
getRejectOld() |
long |
getTimeout() |
void |
setCapacity(int capacity)
Sets the capacity of the resequencer's inbound queue.
|
void |
setComparator(ExpressionResultComparator comparator)
To use a custom comparator
|
void |
setComparatorRef(String comparatorRef)
To use a custom comparator
|
void |
setIgnoreInvalidExchanges(Boolean ignoreInvalidExchanges)
Whether to ignore invalid exchanges
|
void |
setRejectOld(boolean value)
If true, throws an exception when messages older than the last delivered message are processed
|
void |
setTimeout(long timeout)
Sets minimum time to wait for missing elements (messages).
|
getOtherAttributes, setOtherAttributespublic StreamResequencerConfig()
StreamResequencerConfig instance using default
values for capacity (1000) and timeout
(1000L). Elements of the sequence are compared using the
DefaultExchangeComparator.public StreamResequencerConfig(int capacity, long timeout)
StreamResequencerConfig instance using the given
values for capacity and timeout. Elements
of the sequence are compared using the DefaultExchangeComparator.capacity - capacity of the resequencer's inbound queue.timeout - minimum time to wait for missing elements (messages).public StreamResequencerConfig(int capacity, long timeout, ExpressionResultComparator comparator)
StreamResequencerConfig instance using the given
values for capacity and timeout. Elements
of the sequence are compared with the given
ExpressionResultComparator.capacity - capacity of the resequencer's inbound queue.timeout - minimum time to wait for missing elements (messages).comparator - comparator for sequence comparisionpublic StreamResequencerConfig(int capacity, long timeout, Boolean rejectOld)
StreamResequencerConfig instance using the given
values for capacity and timeout. Elements
of the sequence are compared using the DefaultExchangeComparator.capacity - capacity of the resequencer's inbound queue.timeout - minimum time to wait for missing elements (messages).rejectOld - if true, throws an exception when messages older than the last delivered message are processedpublic StreamResequencerConfig(int capacity, long timeout, Boolean rejectOld, ExpressionResultComparator comparator)
StreamResequencerConfig instance using the given
values for capacity and timeout. Elements
of the sequence are compared with the given ExpressionResultComparator.capacity - capacity of the resequencer's inbound queue.timeout - minimum time to wait for missing elements (messages).rejectOld - if true, throws an exception when messages older than the last delivered message are processedcomparator - comparator for sequence comparisionpublic static StreamResequencerConfig getDefault()
StreamResequencerConfig instance using default
values for capacity (1000) and timeout
(1000L). Elements of the sequence are compared using the
DefaultExchangeComparator.StreamResequencerConfig.public int getCapacity()
public void setCapacity(int capacity)
public long getTimeout()
public void setTimeout(long timeout)
public Boolean getIgnoreInvalidExchanges()
public void setIgnoreInvalidExchanges(Boolean ignoreInvalidExchanges)
public ExpressionResultComparator getComparator()
public void setComparator(ExpressionResultComparator comparator)
public String getComparatorRef()
public void setComparatorRef(String comparatorRef)
public void setRejectOld(boolean value)
public Boolean getRejectOld()
Apache Camel