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,
javax.jms.MessageListener listener) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
checkSessionThread() |
void |
onMessage(Message msg,
javax.jms.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
public void pushMessages(ConsumerMessages cm) throws javax.jms.JMSException
MessageConsumerListener
pushMessages
in class MessageConsumerListener
javax.jms.JMSException
public void onMessage(Message msg, javax.jms.MessageListener listener, int ackMode) throws javax.jms.JMSException
onMessage
in class MessageConsumerListener
javax.jms.JMSException
protected boolean checkSessionThread()
checkSessionThread
in class MessageConsumerListener
Copyright © 2018 ScalAgent D.T.. All Rights Reserved.