public class OutboundReceiver extends OutboundConsumer implements QueueReceiver
OutboundReceiver
instance wraps a JMS PTP consumer
for a component involved in outbound messaging.Modifier and Type | Field and Description |
---|---|
static org.objectweb.util.monolog.api.Logger |
logger |
private Queue |
queue
Queue instance to consume messages from.
|
consumer, session, valid
Constructor and Description |
---|
OutboundReceiver(Queue queue,
MessageConsumer consumer,
OutboundSession session)
Constructs an
OutboundReceiver instance. |
Modifier and Type | Method and Description |
---|---|
Queue |
getQueue()
Returns the consumer's queue.
|
checkValidity, close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener
public static org.objectweb.util.monolog.api.Logger logger
private Queue queue
OutboundReceiver(Queue queue, MessageConsumer consumer, OutboundSession session) throws JMSException
OutboundReceiver
instance.JMSException
public Queue getQueue() throws JMSException
getQueue
in interface QueueReceiver
JMSException
Copyright © 2016 ScalAgent D.T.. All Rights Reserved.