org.objectweb.joram.client.jms
Class QueueReceiver

java.lang.Object
  extended by org.objectweb.joram.client.jms.MessageConsumer
      extended by org.objectweb.joram.client.jms.QueueReceiver
All Implemented Interfaces:
javax.jms.MessageConsumer, javax.jms.QueueReceiver

public class QueueReceiver
extends MessageConsumer
implements javax.jms.QueueReceiver

Implements the javax.jms.QueueReceiver interface.


Nested Class Summary
 
Nested classes/interfaces inherited from class org.objectweb.joram.client.jms.MessageConsumer
MessageConsumer.Closer
 
Field Summary
 
Fields inherited from class org.objectweb.joram.client.jms.MessageConsumer
dest, noLocal, queueMode, selector, sess, targetName
 
Constructor Summary
QueueReceiver(QueueSession sess, Destination queue, java.lang.String selector)
          Constructs a receiver.
 
Method Summary
 javax.jms.Queue getQueue()
          API method.
 java.lang.String toString()
          Returns a string view of this receiver.
 
Methods inherited from class org.objectweb.joram.client.jms.MessageConsumer
activateMessageInput, checkClosed, close, doClose, getMessageListener, getMessageSelector, getQueueMode, getTargetName, passivateMessageInput, receive, receive, receiveNoWait, setMessageListener
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface javax.jms.MessageConsumer
close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener
 

Constructor Detail

QueueReceiver

QueueReceiver(QueueSession sess,
              Destination queue,
              java.lang.String selector)
        throws javax.jms.JMSException
Constructs a receiver.

Parameters:
sess - The session the receiver belongs to.
queue - The queue the receiver consumes on.
selector - The selector for filtering messages.
Throws:
javax.jms.IllegalStateException - If the connection is broken.
javax.jms.JMSException - If the creation fails for any other reason.
Method Detail

toString

public java.lang.String toString()
Returns a string view of this receiver.

Overrides:
toString in class MessageConsumer

getQueue

public javax.jms.Queue getQueue()
                         throws javax.jms.JMSException
API method.

Specified by:
getQueue in interface javax.jms.QueueReceiver
Throws:
javax.jms.IllegalStateException - If the receiver is closed.
javax.jms.JMSException


Copyright © 2010 ScalAgent D.T.. All Rights Reserved.