org.objectweb.joram.client.connector

Class OutboundConsumer

Implemented Interfaces:
javax.jms.MessageConsumer
Known Direct 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 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.
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.

Field Details

consumer

protected MessageConsumer consumer
Wrapped JMS consumer.


session

protected OutboundSession session
The OutboundSession this consumer belongs to.

Method Details

checkValidity

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


close

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


getMessageListener

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


getMessageSelector

public String getMessageSelector()
            throws JMSException
Delegates the call to the wrapped JMS consumer.


receive

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


receive

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


receiveNoWait

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


setMessageListener

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


Copyright B) 2004 Scalagent - All rights reserved