class InboundSession extends Object implements jakarta.jms.ServerSession, jakarta.resource.spi.work.Work, jakarta.jms.MessageListener
InboundSession
instance is responsible for processing
delivered messages within a jakarta.resource.spi.Work
instance,
and passing them to a set of application server endpoints.Modifier and Type | Field and Description |
---|---|
private InboundConsumer |
consumer
InboundConsumer instance this session belongs to. |
private jakarta.resource.spi.endpoint.MessageEndpointFactory |
endpointFactory
Application's endpoints factory.
|
static Logger |
logger |
private jakarta.jms.Session |
session
jakarta.jms.Session instance dedicated to processing
the delivered messages. |
private jakarta.resource.spi.work.WorkManager |
workManager
Application server's
WorkManager instance. |
private XAResource |
xaResource
XAResource instance, if any. |
Constructor and Description |
---|
InboundSession(InboundConsumer consumer,
jakarta.resource.spi.work.WorkManager workManager,
jakarta.resource.spi.endpoint.MessageEndpointFactory endpointFactory,
jakarta.jms.XAConnection cnx,
boolean transacted,
int ackMode)
Constructs an
InboundSession instance. |
Modifier and Type | Method and Description |
---|---|
jakarta.jms.Session |
getSession()
Provides the wrapped
jakarta.jms.Session instance for
processing delivered messages. |
void |
onMessage(jakarta.jms.Message message)
Forwards a processed message to an endpoint.
|
void |
release()
jakarta.resource.spi.Work method, not effective. |
void |
run()
Runs the wrapped session for processing the messages.
|
void |
start()
Notifies that the messages are ready to be processed.
|
public static Logger logger
private InboundConsumer consumer
InboundConsumer
instance this session belongs to.private jakarta.resource.spi.work.WorkManager workManager
WorkManager
instance.private jakarta.resource.spi.endpoint.MessageEndpointFactory endpointFactory
private jakarta.jms.Session session
jakarta.jms.Session
instance dedicated to processing
the delivered messages.private XAResource xaResource
XAResource
instance, if any.InboundSession(InboundConsumer consumer, jakarta.resource.spi.work.WorkManager workManager, jakarta.resource.spi.endpoint.MessageEndpointFactory endpointFactory, jakarta.jms.XAConnection cnx, boolean transacted, int ackMode)
InboundSession
instance.consumer
- InboundConsumer creating this session.workManager
- Application server's WorkManager
instance.endpointFactory
- Application's endpoints factory.cnx
- Connection to the underlying JORAM server.transacted
- true
if deliveries occur within a
XA transaction.public jakarta.jms.Session getSession() throws jakarta.jms.JMSException
jakarta.jms.Session
instance for
processing delivered messages.getSession
in interface jakarta.jms.ServerSession
jakarta.jms.JMSException
- Never thrown.public void start() throws jakarta.jms.JMSException
start
in interface jakarta.jms.ServerSession
jakarta.jms.JMSException
- If submitting the processing work fails.public void release()
jakarta.resource.spi.Work
method, not effective.release
in interface jakarta.resource.spi.work.Work
public void run()
public void onMessage(jakarta.jms.Message message)
onMessage
in interface jakarta.jms.MessageListener
Copyright © 2022 ScalAgent D.T.. All rights reserved.