org.codehaus.activemq.ra
Class ServerSessionImpl

java.lang.Object
  extended byorg.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 $

Constructor Summary
ServerSessionImpl(ServerSessionPoolImpl pool, Session session, WorkManager workManager, MessageEndpoint endpoint)
           
 
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()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

ServerSessionImpl

public ServerSessionImpl(ServerSessionPoolImpl pool,
                         Session session,
                         WorkManager workManager,
                         MessageEndpoint endpoint)
                  throws JMSException
Method Detail

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.