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) |
private void |
put(long id,
Message msg) |
(package private) Message |
receive(long timeout,
long msgId) |
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
private final void put(long id, Message msg)
public Message getMessage(long id)
Message receive(long timeout, long msgId) throws JMSException
JMSException
public Message removeMessage(long id)
public void clear()
Copyright © 2019 ScalAgent D.T.. All rights reserved.