|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.joram.client.connector.InboundSession
class InboundSession
An InboundSession
instance is responsible for processing
delivered messages within a javax.resource.spi.Work
instance,
and passing them to a set of application server endpoints.
Field Summary | |
---|---|
private InboundConsumer |
consumer
InboundConsumer instance this session belongs to. |
private javax.resource.spi.endpoint.MessageEndpointFactory |
endpointFactory
Application's endpoints factory. |
private javax.jms.Session |
session
javax.jms.Session instance dedicated to processing
the delivered messages. |
private javax.resource.spi.work.WorkManager |
workManager
Application server's WorkManager instance. |
private javax.transaction.xa.XAResource |
xaResource
XAResource instance, if any. |
Constructor Summary | |
---|---|
InboundSession(InboundConsumer consumer,
javax.resource.spi.work.WorkManager workManager,
javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory,
javax.jms.XAConnection cnx,
boolean transacted,
int ackMode)
Constructs an InboundSession instance. |
Method Summary | |
---|---|
javax.jms.Session |
getSession()
Provides the wrapped javax.jms.Session instance for
processing delivered messages. |
void |
onMessage(javax.jms.Message message)
Forwards a processed message to an endpoint. |
void |
release()
javax.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. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private InboundConsumer consumer
InboundConsumer
instance this session belongs to.
private javax.resource.spi.work.WorkManager workManager
WorkManager
instance.
private javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory
private javax.jms.Session session
javax.jms.Session
instance dedicated to processing
the delivered messages.
private javax.transaction.xa.XAResource xaResource
XAResource
instance, if any.
Constructor Detail |
---|
InboundSession(InboundConsumer consumer, javax.resource.spi.work.WorkManager workManager, javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory, javax.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.Method Detail |
---|
public javax.jms.Session getSession() throws javax.jms.JMSException
javax.jms.Session
instance for
processing delivered messages.
getSession
in interface javax.jms.ServerSession
javax.jms.JMSException
- Never thrown.public void start() throws javax.jms.JMSException
start
in interface javax.jms.ServerSession
javax.jms.JMSException
- If submitting the processing work fails.public void release()
javax.resource.spi.Work
method, not effective.
release
in interface javax.resource.spi.work.Work
public void run()
run
in interface java.lang.Runnable
public void onMessage(javax.jms.Message message)
onMessage
in interface javax.jms.MessageListener
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |