Joram ${version}

org.objectweb.joram.client.connector
Class OutboundConsumer

java.lang.Object
  extended byorg.objectweb.joram.client.connector.OutboundConsumer
All Implemented Interfaces:
javax.jms.MessageConsumer
Direct Known Subclasses:
OutboundReceiver, OutboundSubscriber

public class OutboundConsumer
extends java.lang.Object
implements javax.jms.MessageConsumer

An OutboundConsumer instance wraps a JMS consumer for a component involved in outbound messaging.


Field Summary
protected  javax.jms.MessageConsumer consumer
          Wrapped JMS consumer.
protected  OutboundSession session
          The OutboundSession this consumer belongs to.
 
Method Summary
protected  void checkValidity()
          Checks the validity of the subscriber instance.
 void close()
          Delegates the call to the wrapped JMS consumer.
 javax.jms.MessageListener getMessageListener()
          Forbidden call on a component's outbound consumer, throws a IllegalStateException instance.
 java.lang.String getMessageSelector()
          Delegates the call to the wrapped JMS consumer.
 javax.jms.Message receive()
          Delegates the call to the wrapped JMS consumer.
 javax.jms.Message receive(long timeOut)
          Delegates the call to the wrapped JMS consumer.
 javax.jms.Message receiveNoWait()
          Delegates the call to the wrapped JMS consumer.
 void setMessageListener(javax.jms.MessageListener messageListener)
          Forbidden call on a component's outbound consumer, throws a IllegalStateException instance.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

session

protected OutboundSession session
The OutboundSession this consumer belongs to.


consumer

protected javax.jms.MessageConsumer consumer
Wrapped JMS consumer.

Method Detail

setMessageListener

public void setMessageListener(javax.jms.MessageListener messageListener)
                        throws javax.jms.JMSException
Forbidden call on a component's outbound consumer, throws a IllegalStateException instance.

Specified by:
setMessageListener in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

getMessageListener

public javax.jms.MessageListener getMessageListener()
                                             throws javax.jms.JMSException
Forbidden call on a component's outbound consumer, throws a IllegalStateException instance.

Specified by:
getMessageListener in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

getMessageSelector

public java.lang.String getMessageSelector()
                                    throws javax.jms.JMSException
Delegates the call to the wrapped JMS consumer.

Specified by:
getMessageSelector in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

receive

public javax.jms.Message receive(long timeOut)
                          throws javax.jms.JMSException
Delegates the call to the wrapped JMS consumer.

Specified by:
receive in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

receive

public javax.jms.Message receive()
                          throws javax.jms.JMSException
Delegates the call to the wrapped JMS consumer.

Specified by:
receive in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

receiveNoWait

public javax.jms.Message receiveNoWait()
                                throws javax.jms.JMSException
Delegates the call to the wrapped JMS consumer.

Specified by:
receiveNoWait in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

close

public void close()
           throws javax.jms.JMSException
Delegates the call to the wrapped JMS consumer.

Specified by:
close in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

checkValidity

protected void checkValidity()
                      throws javax.jms.IllegalStateException
Checks the validity of the subscriber instance.

Throws:
javax.jms.IllegalStateException

Joram ${version}

Copyright © 2005 Scalagent - All rights reserved