Package org.ow2.joram.jakarta.connector

Class OutboundReceiver

java.lang.Object

org.ow2.joram.jakarta.connector.OutboundConsumer

org.ow2.joram.jakarta.connector.OutboundReceiver

All Implemented Interfaces:

jakarta.jms.MessageConsumer, jakarta.jms.QueueReceiver, AutoCloseable

public class OutboundReceiver
extends OutboundConsumer
implements jakarta.jms.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 jakarta.jms.Queue	queue	Queue instance to consume messages from.

Fields inherited from class org.ow2.joram.jakarta.connector.OutboundConsumer

consumer, session, valid

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class org.ow2.joram.jakarta.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 jakarta.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 jakarta.jms.Queue queue

Queue instance to consume messages from.

Constructor Detail

OutboundReceiver

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

Constructs an OutboundReceiver instance.

Throws:

jakarta.jms.JMSException

Method Detail

getQueue

public jakarta.jms.Queue getQueue()
                           throws jakarta.jms.JMSException

Returns the consumer's queue.

Specified by:

getQueue in interface jakarta.jms.QueueReceiver

Throws:

jakarta.jms.JMSException