org.apache.activemq.ra
Class InboundContextSupport

java.lang.Object
  extended by org.apache.activemq.ra.InboundContextSupport

public final class InboundContextSupport
extends Object

A helper class used to provide access to the current active InboundContext instance being used to process a message in the current thread so that messages can be produced using the same session.


Method Summary
static InboundContext getActiveSessionAndProducer()
          Returns the current InboundContext used by the current thread which is processing a message.
static void register(InboundContext sessionAndProducer)
          Registers the session and producer which should be called before the MessageEndpoint.beforeDelivery(java.lang.reflect.Method) method is called.
static void unregister(InboundContext sessionAndProducer)
          Unregisters the session and producer which should be called after the MessageEndpoint.afterDelivery() method is called.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

getActiveSessionAndProducer

public static InboundContext getActiveSessionAndProducer()
Returns the current InboundContext used by the current thread which is processing a message. This allows us to access the current Session to send a message using the same underlying session to avoid unnecessary XA or to use regular JMS transactions while using message driven POJOs.

Returns:

register

public static void register(InboundContext sessionAndProducer)
Registers the session and producer which should be called before the MessageEndpoint.beforeDelivery(java.lang.reflect.Method) method is called.

Parameters:
sessionAndProducer -

unregister

public static void unregister(InboundContext sessionAndProducer)
Unregisters the session and producer which should be called after the MessageEndpoint.afterDelivery() method is called.

Parameters:
sessionAndProducer -


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.