public class CorrelationTimeoutMap extends org.apache.camel.support.DefaultTimeoutMap<String,ReplyHandler>
TimeoutMap
which is used to track reply messages which
has been timed out, and thus should trigger the waiting Exchange
to
timeout as well.Constructor and Description |
---|
CorrelationTimeoutMap(ScheduledExecutorService executor,
long requestMapPollTimeMillis) |
Modifier and Type | Method and Description |
---|---|
ReplyHandler |
get(String key) |
boolean |
onEviction(String key,
ReplyHandler value) |
ReplyHandler |
put(String key,
ReplyHandler value,
long timeoutMillis) |
ReplyHandler |
putIfAbsent(String key,
ReplyHandler value,
long timeoutMillis) |
ReplyHandler |
remove(String key) |
void |
setListener(CorrelationListener listener) |
currentTime, doStart, doStop, getExecutor, getKeys, getPurgePollTime, isValidForEviction, purge, run, schedulePoll, size, updateExpireTime
public CorrelationTimeoutMap(ScheduledExecutorService executor, long requestMapPollTimeMillis)
public void setListener(CorrelationListener listener)
public boolean onEviction(String key, ReplyHandler value)
onEviction
in interface org.apache.camel.TimeoutMap<String,ReplyHandler>
onEviction
in class org.apache.camel.support.DefaultTimeoutMap<String,ReplyHandler>
public ReplyHandler get(String key)
get
in interface org.apache.camel.TimeoutMap<String,ReplyHandler>
get
in class org.apache.camel.support.DefaultTimeoutMap<String,ReplyHandler>
public ReplyHandler put(String key, ReplyHandler value, long timeoutMillis)
put
in interface org.apache.camel.TimeoutMap<String,ReplyHandler>
put
in class org.apache.camel.support.DefaultTimeoutMap<String,ReplyHandler>
public ReplyHandler putIfAbsent(String key, ReplyHandler value, long timeoutMillis)
putIfAbsent
in interface org.apache.camel.TimeoutMap<String,ReplyHandler>
putIfAbsent
in class org.apache.camel.support.DefaultTimeoutMap<String,ReplyHandler>
public ReplyHandler remove(String key)
remove
in interface org.apache.camel.TimeoutMap<String,ReplyHandler>
remove
in class org.apache.camel.support.DefaultTimeoutMap<String,ReplyHandler>
Apache Camel