org.apache.camel.component.jms.reply
Class CorrelationTimeoutMap
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.support.DefaultTimeoutMap<String,ReplyHandler>
org.apache.camel.component.jms.reply.CorrelationTimeoutMap
- All Implemented Interfaces:
- Runnable, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService, org.apache.camel.TimeoutMap<String,ReplyHandler>
public class CorrelationTimeoutMap
- extends org.apache.camel.support.DefaultTimeoutMap<String,ReplyHandler>
A TimeoutMap
which is used to track reply messages which
has been timed out, and thus should trigger the waiting Exchange
to
timeout as well.
- Version:
Fields inherited from class org.apache.camel.support.DefaultTimeoutMap |
log |
Fields inherited from class org.apache.camel.support.ServiceSupport |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Methods inherited from class org.apache.camel.support.DefaultTimeoutMap |
currentTime, doStart, doStop, getExecutor, getKeys, getPurgePollTime, isValidForEviction, purge, run, schedulePoll, size, updateExpireTime |
Methods inherited from class org.apache.camel.support.ServiceSupport |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CorrelationTimeoutMap
public CorrelationTimeoutMap(ScheduledExecutorService executor,
long requestMapPollTimeMillis)
setListener
public void setListener(CorrelationListener listener)
onEviction
public boolean onEviction(String key,
ReplyHandler value)
- Specified by:
onEviction
in interface org.apache.camel.TimeoutMap<String,ReplyHandler>
- Overrides:
onEviction
in class org.apache.camel.support.DefaultTimeoutMap<String,ReplyHandler>
get
public ReplyHandler get(String key)
- Specified by:
get
in interface org.apache.camel.TimeoutMap<String,ReplyHandler>
- Overrides:
get
in class org.apache.camel.support.DefaultTimeoutMap<String,ReplyHandler>
put
public void put(String key,
ReplyHandler value,
long timeoutMillis)
- Specified by:
put
in interface org.apache.camel.TimeoutMap<String,ReplyHandler>
- Overrides:
put
in class org.apache.camel.support.DefaultTimeoutMap<String,ReplyHandler>
remove
public ReplyHandler remove(String key)
- Specified by:
remove
in interface org.apache.camel.TimeoutMap<String,ReplyHandler>
- Overrides:
remove
in class org.apache.camel.support.DefaultTimeoutMap<String,ReplyHandler>
Apache Camel