public class SingleSessionConsumer extends MessageConsumerListener
MessageConsumerListener.Status
Modifier and Type | Field and Description |
---|---|
private Session |
sess |
logger
Constructor and Description |
---|
SingleSessionConsumer(boolean queueMode,
boolean durable,
String selector,
String destName,
String targetName,
Session session,
MessageListener listener) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
checkSessionThread() |
void |
onMessage(Message msg,
MessageListener listener,
int ackMode) |
void |
pushMessages(ConsumerMessages cm)
Pushes the received messages.
|
ack, activateListener, activateMessageInput, addMessageListener, close, errorReceived, getDestName, getMessageListener, getMessageListenersSize, getQueueMode, getStatus, getTargetName, isClosed, onMessage, passivateMessageInput, removeMessageListener, replyAborted, replyReceived, setStatus, start
private Session sess
SingleSessionConsumer(boolean queueMode, boolean durable, String selector, String destName, String targetName, Session session, MessageListener listener)
public void pushMessages(ConsumerMessages cm) throws JMSException
MessageConsumerListener
pushMessages
in class MessageConsumerListener
JMSException
public void onMessage(Message msg, MessageListener listener, int ackMode) throws JMSException
onMessage
in class MessageConsumerListener
JMSException
protected boolean checkSessionThread()
checkSessionThread
in class MessageConsumerListener
Copyright © 2022 ScalAgent D.T.. All rights reserved.