org.objectweb.joram.client.connector
Class OutboundConsumer

java.lang.Object
  org.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