org.codehaus.activemq.ra
Class ServerSessionImpl
java.lang.Object
org.codehaus.activemq.ra.ServerSessionImpl
- All Implemented Interfaces:
- Runnable, ServerSession, SessionAndProducer, Work
- public class ServerSessionImpl
- extends Object
- implements ServerSession, SessionAndProducer, Work
- Version:
- $Revision: 1.6.2.1 $
Method Summary |
MessageProducer |
getMessageProducer()
Lazily creates a message producer that can be used to send messages using the
same JMS Session which is being used to dispatch messages which minimises the XA
overheard of consuming and producing or allows JMS transactions to be used for consuming
and producing messages. |
Session |
getSession()
Returns the current session being used to process a JMS message in the current thread. |
void |
release()
|
void |
run()
|
void |
start()
|
String |
toString()
|
ServerSessionImpl
public ServerSessionImpl(ServerSessionPoolImpl pool,
Session session,
WorkManager workManager,
MessageEndpoint endpoint)
throws JMSException
getSession
public Session getSession()
throws JMSException
- Description copied from interface:
SessionAndProducer
- Returns the current session being used to process a JMS message in the current thread.
- Specified by:
getSession
in interface ServerSession
- Throws:
JMSException
getMessageProducer
public MessageProducer getMessageProducer()
throws JMSException
- Description copied from interface:
SessionAndProducer
- Lazily creates a message producer that can be used to send messages using the
same JMS Session which is being used to dispatch messages which minimises the XA
overheard of consuming and producing or allows JMS transactions to be used for consuming
and producing messages.
- Specified by:
getMessageProducer
in interface SessionAndProducer
- Returns:
- the current message producer or a new one is lazily created, using a null
destination so the destination must be specified on a send() method.
- Throws:
JMSException
start
public void start()
throws JMSException
- Specified by:
start
in interface ServerSession
- Throws:
JMSException
- See Also:
ServerSession.start()
run
public void run()
- Specified by:
run
in interface Runnable
- See Also:
Runnable.run()
release
public void release()
- Specified by:
release
in interface Work
- See Also:
Work.release()
toString
public String toString()
- See Also:
Object.toString()
Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.