类 AbstractMessageEndpointFactory

字段详细资料

• logger

  protected final Log logger

  Logger available to subclasses

构造器详细资料

• AbstractMessageEndpointFactory

  public AbstractMessageEndpointFactory()

方法详细资料

• setTransactionManager

  public void setTransactionManager​(Object transactionManager)

  Set the XA transaction manager to use for wrapping endpoint invocations, enlisting the endpoint resource in each such transaction.

  The passed-in object may be a transaction manager which implements Spring's TransactionFactory interface, or a plain TransactionManager.

  If no transaction manager is specified, the endpoint invocation will simply not be wrapped in an XA transaction. Check out your resource provider's ActivationSpec documentation for local transaction options of your particular provider.

  另请参阅:

  setTransactionName(java.lang.String), setTransactionTimeout(int)

• setTransactionFactory

  public void setTransactionFactory​(TransactionFactory transactionFactory)

  Set the Spring TransactionFactory to use for wrapping endpoint invocations, enlisting the endpoint resource in each such transaction.

  Alternatively, specify an appropriate transaction manager through the "transactionManager" property.

  If no transaction factory is specified, the endpoint invocation will simply not be wrapped in an XA transaction. Check out your resource provider's ActivationSpec documentation for local transaction options of your particular provider.

  另请参阅:

  setTransactionName(java.lang.String), setTransactionTimeout(int)

• setTransactionName

  public void setTransactionName​(String transactionName)

  Specify the name of the transaction, if any.

  Default is none. A specified name will be passed on to the transaction manager, allowing to identify the transaction in a transaction monitor.

• setTransactionTimeout

  public void setTransactionTimeout​(int transactionTimeout)

  Specify the transaction timeout, if any.

  Default is -1: rely on the transaction manager's default timeout. Specify a concrete timeout to restrict the maximum duration of each endpoint invocation.

• setBeanName

  public void setBeanName​(String beanName)

  Set the name of this message endpoint. Populated with the bean name automatically when defined within Spring's bean factory.

  指定者:

  setBeanName 在接口中 BeanNameAware

  参数:

  beanName - the name of the bean in the factory. Note that this name is the actual bean name used in the factory, which may differ from the originally specified name: in particular for inner bean names, the actual bean name might have been made unique through appending "#..." suffixes. Use the BeanFactoryUtils.originalBeanName(String) method to extract the original bean name (without suffix), if desired.

• getActivationName

  public String getActivationName()

  Implementation of the JCA 1.7 #getActivationName() method, returning the bean name as set on this MessageEndpointFactory.

  另请参阅:

  setBeanName(java.lang.String)

• isDeliveryTransacted

  public boolean isDeliveryTransacted​(Method method)
                               throws NoSuchMethodException

  This implementation returns true if a transaction manager has been specified; false otherwise.

  指定者:

  isDeliveryTransacted 在接口中 MessageEndpointFactory

  抛出:

  NoSuchMethodException

  另请参阅:

  setTransactionManager(java.lang.Object), setTransactionFactory(org.springframework.transaction.jta.TransactionFactory)

• createEndpoint

  public MessageEndpoint createEndpoint​(XAResource xaResource)
                                 throws UnavailableException

  The standard JCA 1.5 version of createEndpoint.

  This implementation delegates to createEndpointInternal(), initializing the endpoint's XAResource before the endpoint gets invoked.

  指定者:

  createEndpoint 在接口中 MessageEndpointFactory

  抛出:

  UnavailableException

• createEndpoint

  public MessageEndpoint createEndpoint​(XAResource xaResource,
                                        long timeout)
                                 throws UnavailableException

  The alternative JCA 1.6 version of createEndpoint.

  This implementation delegates to createEndpointInternal(), ignoring the specified timeout. It is only here for JCA 1.6 compliance.

  抛出:

  UnavailableException

• createEndpointInternal

  protected abstract AbstractMessageEndpointFactory.AbstractMessageEndpoint createEndpointInternal()
                                                                                            throws UnavailableException

  Create the actual endpoint instance, as a subclass of the AbstractMessageEndpointFactory.AbstractMessageEndpoint inner class of this factory.

  返回:

  the actual endpoint instance (never null)

  抛出:

  UnavailableException - if no endpoint is available at present