public class MessageSelectorCreator extends Object implements CorrelationListener
Modifier and Type | Field and Description |
---|---|
protected ConcurrentSkipListSet<String> |
correlationIds |
protected boolean |
dirty |
protected StringBuilder |
expression |
protected static org.slf4j.Logger |
LOG |
protected CorrelationTimeoutMap |
timeoutMap |
Constructor and Description |
---|
MessageSelectorCreator(CorrelationTimeoutMap timeoutMap) |
Modifier and Type | Method and Description |
---|---|
String |
get() |
void |
onEviction(String key)
Callback when a correlation id is evicted due timeout
|
void |
onPut(String key)
Callback when a new correlation id is added
|
void |
onRemove(String key)
Callback when a correlation id is removed
|
protected static final org.slf4j.Logger LOG
protected final CorrelationTimeoutMap timeoutMap
protected final ConcurrentSkipListSet<String> correlationIds
protected volatile boolean dirty
protected StringBuilder expression
public MessageSelectorCreator(CorrelationTimeoutMap timeoutMap)
public String get()
public void onPut(String key)
CorrelationListener
onPut
in interface CorrelationListener
key
- the correlation idpublic void onRemove(String key)
CorrelationListener
onRemove
in interface CorrelationListener
key
- the correlation idpublic void onEviction(String key)
CorrelationListener
onEviction
in interface CorrelationListener
key
- the correlation idApache Camel