org.objectweb.joram.client.jms
Class SingleSessionConsumer
java.lang.Object
org.objectweb.joram.client.jms.MessageConsumerListener
org.objectweb.joram.client.jms.SingleSessionConsumer
- All Implemented Interfaces:
- ReplyListener
public class SingleSessionConsumer
- extends MessageConsumerListener
Constructor Summary |
SingleSessionConsumer(boolean queueMode,
boolean durable,
java.lang.String selector,
java.lang.String targetName,
Session session,
javax.jms.MessageListener listener)
|
Methods inherited from class org.objectweb.joram.client.jms.MessageConsumerListener |
ack, activateListener, activateMessageInput, close, getMessageListener, getQueueMode, getStatus, getTargetName, isClosed, onMessage, passivateMessageInput, replyAborted, replyReceived, setStatus, start |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
sess
private Session sess
SingleSessionConsumer
SingleSessionConsumer(boolean queueMode,
boolean durable,
java.lang.String selector,
java.lang.String targetName,
Session session,
javax.jms.MessageListener listener)
pushMessages
public void pushMessages(ConsumerMessages cm)
throws javax.jms.JMSException
- Description copied from class:
MessageConsumerListener
- Pushes the received messages.
Currently two behaviors:
1- SingleSessionConsumer pushes the message
in a single session (standard JMS)
2- MultiSessionConsumer pushes the message
in several session (from a session pool)
- Specified by:
pushMessages
in class MessageConsumerListener
- Throws:
javax.jms.JMSException
onMessage
public void onMessage(Message msg,
javax.jms.MessageListener listener,
int ackMode)
throws javax.jms.JMSException
- Specified by:
onMessage
in class MessageConsumerListener
- Throws:
javax.jms.JMSException
Copyright © 2010 ScalAgent D.T.. All Rights Reserved.