Package org.apache.activemq.ra

Class InboundContextSupport

java.lang.Object
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 Details

    • 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 javax.resource.spi.endpoint.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 javax.resource.spi.endpoint.MessageEndpoint#afterDelivery() method is called.
      Parameters:
      sessionAndProducer -