Field Detail

• state

  protected org.apache.openejb.core.mdb.State state

• isAmq

  protected volatile java.lang.Boolean isAmq

• instance

  protected java.lang.Object instance

• container

  protected final BaseMdbContainer container

Constructor Detail

• PoolEndpointHandler

  public PoolEndpointHandler(BaseMdbContainer container,
                             BeanContext deployment,
                             MdbInstanceManager instanceManager,
                             javax.transaction.xa.XAResource xaResource)
                      throws UnavailableException

  Throws:

  UnavailableException

Method Detail

• beforeDelivery

  public void beforeDelivery(java.lang.reflect.Method method)
                      throws ApplicationServerInternalException

  Throws:

  ApplicationServerInternalException

• recreateInstance

  protected void recreateInstance(boolean exceptionAlreadyThrown)
                           throws UnavailableException

  Throws:

  UnavailableException

• afterDelivery

  public void afterDelivery()
                     throws ApplicationServerInternalException,
                            UnavailableException

  Throws:

  ApplicationServerInternalException

  UnavailableException

• release

  public void release()

• invoke

  public java.lang.Object invoke(java.lang.Object proxy,
                                 java.lang.reflect.Method method,
                                 java.lang.Object[] args)
                          throws java.lang.Throwable

  Specified by:

  invoke in interface java.lang.reflect.InvocationHandler

  Throws:

  java.lang.Throwable

• deliverMessage

  public java.lang.Object deliverMessage(java.lang.reflect.Method method,
                                         java.lang.Object[] args)
                                  throws java.lang.Throwable

  Throws:

  java.lang.Throwable