Package org.objectweb.joram.client.connector

Class OutboundConsumer

java.lang.Object

org.objectweb.joram.client.connector.OutboundConsumer

All Implemented Interfaces:

AutoCloseable, MessageConsumer

Direct Known Subclasses:

OutboundReceiver, OutboundSubscriber

public class OutboundConsumer
extends Object
implements MessageConsumer

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

Field Summary

Fields

Modifier and Type	Field	Description
protected MessageConsumer	consumer	Wrapped JMS consumer.
private static boolean	DEBUG
private static Logger	logger
protected OutboundSession	session	The OutboundSession this consumer belongs to.
(package private) boolean	valid	false if consumer is no more valid.

Constructor Summary

Constructors

Constructor	Description
OutboundConsumer(MessageConsumer consumer, OutboundSession session)	Constructs an OutboundConsumer instance.

Method Summary

Modifier and Type	Method	Description
protected void	checkValidity()	Checks the validity of the subscriber instance.
void	close()	Delegates the call to the wrapped JMS consumer.
MessageListener	getMessageListener()	Forbidden call on a component's outbound consumer, throws a IllegalStateException instance.
String	getMessageSelector()	Delegates the call to the wrapped JMS consumer.
Message	receive()	Delegates the call to the wrapped JMS consumer.
Message	receive(long timeOut)	Delegates the call to the wrapped JMS consumer.
Message	receiveNoWait()	Delegates the call to the wrapped JMS consumer.
void	setMessageListener(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

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

session

protected OutboundSession session

The OutboundSession this consumer belongs to.

consumer

protected MessageConsumer consumer

Wrapped JMS consumer.

valid

boolean valid

false if consumer is no more valid.

Constructor Detail

OutboundConsumer

OutboundConsumer(MessageConsumer consumer,
                 OutboundSession session)

Constructs an OutboundConsumer instance.

Parameters:

consumer - JMS consumer to wrap.

session - The OutboundSession this consumer belongs to.

Method Detail

checkValidity

protected void checkValidity()
                      throws IllegalStateException

Checks the validity of the subscriber instance.

Throws:

IllegalStateException

setMessageListener

public void setMessageListener(MessageListener messageListener)
                        throws JMSException

Forbidden call on a component's outbound consumer, throws a IllegalStateException instance.

Specified by:

setMessageListener in interface MessageConsumer

Throws:

JMSException

getMessageListener

public MessageListener getMessageListener()
                                   throws JMSException

Forbidden call on a component's outbound consumer, throws a IllegalStateException instance.

Specified by:

getMessageListener in interface MessageConsumer

Throws:

JMSException

getMessageSelector

public String getMessageSelector()
                          throws JMSException

Delegates the call to the wrapped JMS consumer.

Specified by:

getMessageSelector in interface MessageConsumer

Throws:

JMSException

receive

public Message receive(long timeOut)
                throws JMSException

Delegates the call to the wrapped JMS consumer.

Specified by:

receive in interface MessageConsumer

Throws:

JMSException

receive

public Message receive()
                throws JMSException

Delegates the call to the wrapped JMS consumer.

Specified by:

receive in interface MessageConsumer

Throws:

JMSException

receiveNoWait

public Message receiveNoWait()
                      throws JMSException

Delegates the call to the wrapped JMS consumer.

Specified by:

receiveNoWait in interface MessageConsumer

Throws:

JMSException

close

public void close()
           throws JMSException

Delegates the call to the wrapped JMS consumer.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface MessageConsumer

Throws:

JMSException