org.apache.camel.component.jms.reply
Class CorrelationMap

java.lang.Object
  org.apache.camel.impl.ServiceSupport
      org.apache.camel.util.DefaultTimeoutMap<String,ReplyHandler>
          org.apache.camel.component.jms.reply.CorrelationMap

All Implemented Interfaces:

Runnable, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.util.TimeoutMap<String,ReplyHandler>

public class CorrelationMap
extends org.apache.camel.util.DefaultTimeoutMap<String,ReplyHandler>

Version:

Field Summary

Fields inherited from class org.apache.camel.util.DefaultTimeoutMap

log

Constructor Summary

CorrelationMap(ScheduledExecutorService executor, long requestMapPollTimeMillis)

Method Summary

boolean	onEviction(String key, ReplyHandler value)
void	put(String key, ReplyHandler value, long timeoutMillis)

Methods inherited from class org.apache.camel.util.DefaultTimeoutMap

currentTime, doStart, doStop, get, getExecutor, getKeys, getPurgePollTime, isValidForEviction, purge, remove, run, schedulePoll, size, updateExpireTime

Methods inherited from class org.apache.camel.impl.ServiceSupport

addChildService, doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, removeChildService, resume, shutdown, start, start, stop, suspend

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CorrelationMap

public CorrelationMap(ScheduledExecutorService executor,
                      long requestMapPollTimeMillis)

Method Detail

onEviction

public boolean onEviction(String key,
                          ReplyHandler value)

Specified by:

onEviction in interface org.apache.camel.util.TimeoutMap<String,ReplyHandler>

Overrides:

onEviction in class org.apache.camel.util.DefaultTimeoutMap<String,ReplyHandler>

put

public void put(String key,
                ReplyHandler value,
                long timeoutMillis)

Specified by:

put in interface org.apache.camel.util.TimeoutMap<String,ReplyHandler>

Overrides:

put in class org.apache.camel.util.DefaultTimeoutMap<String,ReplyHandler>