Package org.objectweb.joram.tools.rest.jms

Class ConsumerContext

java.lang.Object

org.objectweb.joram.tools.rest.jms.SessionContext

org.objectweb.joram.tools.rest.jms.ConsumerContext

public final class ConsumerContext
extends SessionContext

Field Summary

Fields

Modifier and Type	Field	Description
private int	called
private jakarta.jms.JMSConsumer	consumer
private int	delivered
private ConcurrentHashMap<Long,jakarta.jms.Message>	messages
private int	redelivered

Fields inherited from class org.objectweb.joram.tools.rest.jms.SessionContext

lastId

Constructor Summary

Constructors

Constructor	Description
ConsumerContext(RestClientContext clientCtx)

Method Summary

Modifier and Type	Method	Description
void	clear()
jakarta.jms.JMSConsumer	getConsumer()
long	getId(jakarta.jms.Message message)
jakarta.jms.Message	getMessage(long id)
private void	put(long id, jakarta.jms.Message msg)
(package private) jakarta.jms.Message	receive(long timeout, long msgId)
jakarta.jms.Message	removeMessage(long id)
void	setConsumer(jakarta.jms.JMSConsumer consumer)
String	toString()

Methods inherited from class org.objectweb.joram.tools.rest.jms.SessionContext

getClientCtx, getDest, getJmsContext, getLastId, incLastId, setDest, setJmsContext, setLastId, viewLastId

Methods inherited from class java.lang.Object

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

Field Detail

consumer

private jakarta.jms.JMSConsumer consumer

messages

private ConcurrentHashMap<Long,jakarta.jms.Message> messages

called

private int called

delivered

private int delivered

redelivered

private int redelivered

Constructor Detail

ConsumerContext

public ConsumerContext(RestClientContext clientCtx)

Method Detail

getConsumer

public jakarta.jms.JMSConsumer getConsumer()

Returns:

the consumer

setConsumer

public void setConsumer(jakarta.jms.JMSConsumer consumer)

Parameters:

consumer - the consumer to set

getId

public long getId(jakarta.jms.Message message)
           throws jakarta.jms.JMSException

Throws:

jakarta.jms.JMSException

put

private final void put(long id,
                       jakarta.jms.Message msg)

getMessage

public jakarta.jms.Message getMessage(long id)

receive

jakarta.jms.Message receive(long timeout,
                            long msgId)
                     throws jakarta.jms.JMSException

Throws:

jakarta.jms.JMSException

removeMessage

public jakarta.jms.Message removeMessage(long id)

clear

public void clear()

toString

public String toString()

Overrides:

toString in class SessionContext