org.objectweb.joram.client.connector
Class OutboundConsumer
java.lang.Object
org.objectweb.joram.client.connector.OutboundConsumer
- javax.jms.MessageConsumer
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.
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.
|
consumer
protected MessageConsumer consumer
Wrapped JMS consumer.
session
protected OutboundSession session
The OutboundSession
this consumer belongs to.
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