org.objectweb.joram.client.jms
Class SingleSessionConsumer

java.lang.Object
  extended by org.objectweb.joram.client.jms.MessageConsumerListener
      extended by org.objectweb.joram.client.jms.SingleSessionConsumer
All Implemented Interfaces:
ReplyListener

public class SingleSessionConsumer
extends MessageConsumerListener


Nested Class Summary
 
Nested classes/interfaces inherited from class org.objectweb.joram.client.jms.MessageConsumerListener
MessageConsumerListener.Status
 
Field Summary
private  Session sess
           
 
Fields inherited from class org.objectweb.joram.client.jms.MessageConsumerListener
logger
 
Constructor Summary
SingleSessionConsumer(boolean queueMode, boolean durable, java.lang.String selector, java.lang.String targetName, Session session, javax.jms.MessageListener listener)
           
 
Method Summary
 void onMessage(Message msg, javax.jms.MessageListener listener, int ackMode)
           
 void pushMessages(ConsumerMessages cm)
          Pushes the received messages.
 
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
 

Field Detail

sess

private Session sess
Constructor Detail

SingleSessionConsumer

SingleSessionConsumer(boolean queueMode,
                      boolean durable,
                      java.lang.String selector,
                      java.lang.String targetName,
                      Session session,
                      javax.jms.MessageListener listener)
Method Detail

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.