public class OutboundReceiver extends OutboundConsumer implements jakarta.jms.QueueReceiver
OutboundReceiver
instance wraps a JMS PTP consumer
for a component involved in outbound messaging.Modifier and Type | Field and Description |
---|---|
static Logger |
logger |
private jakarta.jms.Queue |
queue
Queue instance to consume messages from.
|
consumer, session, valid
Constructor and Description |
---|
OutboundReceiver(jakarta.jms.Queue queue,
jakarta.jms.MessageConsumer consumer,
OutboundSession session)
Constructs an
OutboundReceiver instance. |
Modifier and Type | Method and Description |
---|---|
jakarta.jms.Queue |
getQueue()
Returns the consumer's queue.
|
checkValidity, close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener
public static Logger logger
private jakarta.jms.Queue queue
OutboundReceiver(jakarta.jms.Queue queue, jakarta.jms.MessageConsumer consumer, OutboundSession session) throws jakarta.jms.JMSException
OutboundReceiver
instance.jakarta.jms.JMSException
Copyright © 2023 ScalAgent D.T.. All rights reserved.