public class ConsumerContext extends SessionContext
Modifier and Type | Field and Description |
---|---|
private javax.jms.JMSConsumer |
consumer |
private ConcurrentHashMap<Long,javax.jms.Message> |
messages |
lastId
Constructor and Description |
---|
ConsumerContext(RestClientContext clientCtx) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
javax.jms.JMSConsumer |
getConsumer() |
long |
getId(javax.jms.Message message) |
javax.jms.Message |
getMessage(long id) |
private void |
put(long id,
javax.jms.Message msg) |
(package private) javax.jms.Message |
receive(long timeout,
long msgId) |
javax.jms.Message |
removeMessage(long id) |
void |
setConsumer(javax.jms.JMSConsumer consumer) |
getClientCtx, getDest, getJmsContext, getLastId, incLastId, setDest, setJmsContext, setLastId
private javax.jms.JMSConsumer consumer
private ConcurrentHashMap<Long,javax.jms.Message> messages
public ConsumerContext(RestClientContext clientCtx)
public javax.jms.JMSConsumer getConsumer()
public void setConsumer(javax.jms.JMSConsumer consumer)
consumer
- the consumer to setpublic long getId(javax.jms.Message message) throws javax.jms.JMSException
javax.jms.JMSException
private final void put(long id, javax.jms.Message msg)
public javax.jms.Message getMessage(long id)
javax.jms.Message receive(long timeout, long msgId) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.Message removeMessage(long id)
public void clear()
Copyright © 2018 ScalAgent D.T.. All Rights Reserved.