Package org.objectweb.joram.client.connector

Class OutboundReceiver

java.lang.Object

org.objectweb.joram.client.connector.OutboundConsumer

org.objectweb.joram.client.connector.OutboundReceiver

All Implemented Interfaces:

AutoCloseable, MessageConsumer, QueueReceiver

public class OutboundReceiver
extends OutboundConsumer
implements QueueReceiver

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

Field Summary

Fields

Modifier and Type	Field	Description
private static boolean	DEBUG
private static Logger	logger
private Queue	queue	Queue instance to consume messages from.

Fields inherited from class org.objectweb.joram.client.connector.OutboundConsumer

consumer, session, valid

Constructor Summary

Constructors

Constructor	Description
OutboundReceiver(Queue queue, MessageConsumer consumer, OutboundSession session)	Constructs an OutboundReceiver instance.

Method Summary

Modifier and Type	Method	Description
Queue	getQueue()	Returns the consumer's queue.

Methods inherited from class org.objectweb.joram.client.connector.OutboundConsumer

checkValidity, close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface javax.jms.MessageConsumer

close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener

Field Detail

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

queue

private Queue queue

Queue instance to consume messages from.

Constructor Detail

OutboundReceiver

OutboundReceiver(Queue queue,
                 MessageConsumer consumer,
                 OutboundSession session)
          throws JMSException

Constructs an OutboundReceiver instance.

Throws:

JMSException

Method Detail

getQueue

public Queue getQueue()
               throws JMSException

Returns the consumer's queue.

Specified by:

getQueue in interface QueueReceiver

Throws:

JMSException