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