public class ConsumerContext extends SessionContext
Modifier and Type | Field and Description |
---|---|
private int |
called |
private JMSConsumer |
consumer |
private int |
delivered |
private ConcurrentHashMap<Long,Message> |
messages |
private int |
redelivered |
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) |
String |
toString() |
getClientCtx, getDest, getJmsContext, getLastId, incLastId, setDest, setJmsContext, setLastId, viewLastId
private JMSConsumer consumer
private ConcurrentHashMap<Long,Message> messages
private int called
private int delivered
private int redelivered
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()
public String toString()
toString
in class SessionContext
Copyright © 2021 ScalAgent D.T.. All rights reserved.