Package org.ow2.joram.jakarta.jms

Class SingleSessionConsumer

java.lang.Object

org.ow2.joram.jakarta.jms.MessageConsumerListener

org.ow2.joram.jakarta.jms.SingleSessionConsumer

All Implemented Interfaces:

ReplyListener

public class SingleSessionConsumer
extends MessageConsumerListener

Nested Class Summary

Nested classes/interfaces inherited from class org.ow2.joram.jakarta.jms.MessageConsumerListener

MessageConsumerListener.Status

Field Summary

Fields

Modifier and Type	Field	Description
private Session	sess

Constructor Summary

Constructors

Constructor	Description
SingleSessionConsumer(boolean queueMode, boolean durable, String selector, String destName, String targetName, Session session, jakarta.jms.MessageListener listener)

Method Summary

Modifier and Type	Method	Description
protected boolean	checkSessionThread()
void	onMessage(Message msg, jakarta.jms.MessageListener listener, int ackMode)
void	pushMessages(ConsumerMessages cm)	Pushes the received messages.

Methods inherited from class org.ow2.joram.jakarta.jms.MessageConsumerListener

ack, activateListener, activateMessageInput, addMessageListener, close, errorReceived, getDestName, getMessageListener, getMessageListenersSize, getQueueMode, getStatus, getTargetName, isClosed, onMessage, passivateMessageInput, removeMessageListener, 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,
                      String selector,
                      String destName,
                      String targetName,
                      Session session,
                      jakarta.jms.MessageListener listener)

Method Detail

pushMessages

public void pushMessages(ConsumerMessages cm)
                  throws jakarta.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:

jakarta.jms.JMSException

onMessage

public void onMessage(Message msg,
                      jakarta.jms.MessageListener listener,
                      int ackMode)
               throws jakarta.jms.JMSException

Specified by:

onMessage in class MessageConsumerListener

Throws:

jakarta.jms.JMSException

checkSessionThread

protected boolean checkSessionThread()

Specified by:

checkSessionThread in class MessageConsumerListener

Returns:

true if the currentThread is the SessionThread.