public class OutboundReceiver extends OutboundConsumer implements javax.jms.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 javax.jms.Queue |
queue
Queue instance to consume messages from.
|
consumer, session, valid
Constructor and Description |
---|
OutboundReceiver(javax.jms.Queue queue,
javax.jms.MessageConsumer consumer,
OutboundSession session)
Constructs an
OutboundReceiver instance. |
Modifier and Type | Method and Description |
---|---|
javax.jms.Queue |
getQueue()
Returns the consumer's queue.
|
checkValidity, close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener
public static org.objectweb.util.monolog.api.Logger logger
private javax.jms.Queue queue
OutboundReceiver(javax.jms.Queue queue, javax.jms.MessageConsumer consumer, OutboundSession session) throws javax.jms.JMSException
OutboundReceiver
instance.javax.jms.JMSException
Copyright © 2018 ScalAgent D.T.. All Rights Reserved.