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 |
---|---|
void |
onMessage(Message msg,
MessageListener listener,
int ackMode) |
void |
pushMessages(ConsumerMessages cm)
Pushes the received messages.
|
ack, activateListener, activateMessageInput, close, errorReceived, getDestName, getMessageListener, getQueueMode, getStatus, getTargetName, isClosed, onMessage, passivateMessageInput, 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
Copyright © 2013 ScalAgent D.T.. All Rights Reserved.