Package org.springframework.jms.support

Class JmsAccessor

java.lang.Object
org.springframework.jms.support.JmsAccessor
All Implemented Interfaces:
InitializingBean
Direct Known Subclasses:
JmsDestinationAccessor
public abstract class JmsAccessor extends Object implements InitializingBean
Base class for JmsTemplate and other JMS-accessing gateway helpers, defining common properties such as the JMS ConnectionFactory to operate on. The subclass JmsDestinationAccessor adds further, destination-related properties.

Not intended to be used directly. See JmsTemplate.

Since:
1.2
Author:
Juergen Hoeller
See Also:

  • Field Details

    • logger

      protected final Log logger
      Logger available to subclasses.

  • Constructor Details

    • JmsAccessor

      public JmsAccessor()

  • Method Details

    • setConnectionFactory

      public void setConnectionFactory(@Nullable ConnectionFactory connectionFactory)
      Set the ConnectionFactory to use for obtaining JMS Connections.

    • getConnectionFactory

      @Nullable public ConnectionFactory getConnectionFactory()
      Return the ConnectionFactory that this accessor uses for obtaining JMS Connections.

    • obtainConnectionFactory

      protected final ConnectionFactory obtainConnectionFactory()
      Obtain the ConnectionFactory for actual use.
      Returns:
      the ConnectionFactory (never null)
      Throws:
      IllegalStateException - in case of no ConnectionFactory set
      Since:
      5.0

    • setSessionTransacted

      public void setSessionTransacted(boolean sessionTransacted)
      Set the transaction mode that is used when creating a JMS Session. Default is "false".

      Note that within a JTA transaction, the parameters passed to create(Queue/Topic)Session(boolean transacted, int acknowledgeMode) method are not taken into account. Depending on the Jakarta EE transaction context, the container makes its own decisions on these values. Analogously, these parameters are not taken into account within a locally managed transaction either, since the accessor operates on an existing JMS Session in this case.

      Setting this flag to "true" will use a short local JMS transaction when running outside a managed transaction, and a synchronized local JMS transaction in case of a managed transaction (other than an XA transaction) being present. This has the effect of a local JMS transaction being managed alongside the main transaction (which might be a native JDBC transaction), with the JMS transaction committing right after the main transaction.

      See Also:

    • isSessionTransacted

      public boolean isSessionTransacted()
      Return whether the JMS sessions used by this accessor are supposed to be transacted.
      See Also:

    • setSessionAcknowledgeModeName

      public void setSessionAcknowledgeModeName(String constantName)
      Set the JMS acknowledgement mode by the name of the corresponding constant in the JMS Session interface, e.g. "CLIENT_ACKNOWLEDGE".

      If you want to use vendor-specific extensions to the acknowledgement mode, use setSessionAcknowledgeMode(int) instead.

      Parameters:
      constantName - the name of the Session acknowledge mode constant
      See Also:

    • setSessionAcknowledgeMode

      public void setSessionAcknowledgeMode(int sessionAcknowledgeMode)
      Set the JMS acknowledgement mode that is used when creating a JMS Session to send a message.

      Default is Session.AUTO_ACKNOWLEDGE.

      Vendor-specific extensions to the acknowledgement mode can be set here as well.

      Note that inside an EJB, the parameters to the create(Queue/Topic)Session(boolean transacted, int acknowledgeMode) method are not taken into account. Depending on the transaction context in the EJB, the container makes its own decisions on these values. See section 17.3.5 of the EJB spec.

      Parameters:
      sessionAcknowledgeMode - the acknowledgement mode constant
      See Also:

    • getSessionAcknowledgeMode

      public int getSessionAcknowledgeMode()
      Return the acknowledgement mode for JMS sessions.

    • afterPropertiesSet

      public void afterPropertiesSet()
      Description copied from interface: InitializingBean
      Invoked by the containing BeanFactory after it has set all bean properties and satisfied BeanFactoryAware, ApplicationContextAware etc.

      This method allows the bean instance to perform validation of its overall configuration and final initialization when all bean properties have been set.

      Specified by:
      afterPropertiesSet in interface InitializingBean

    • convertJmsAccessException

      protected JmsException convertJmsAccessException(JMSException ex)
      Convert the specified checked JMSException to a Spring runtime JmsException equivalent.

      The default implementation delegates to the JmsUtils.convertJmsAccessException(jakarta.jms.JMSException) method.

      Parameters:
      ex - the original checked JMSException to convert
      Returns:
      the Spring runtime JmsException wrapping ex
      See Also:

    • createConnection

      protected Connection createConnection() throws JMSException
      Create a JMS Connection via this template's ConnectionFactory.

      This implementation uses JMS 1.1 API.

      Returns:
      the new JMS Connection
      Throws:
      JMSException - if thrown by JMS API methods
      See Also:

    • createSession

      protected Session createSession(Connection con) throws JMSException
      Create a JMS Session for the given Connection.

      This implementation uses JMS 1.1 API.

      Parameters:
      con - the JMS Connection to create a Session for
      Returns:
      the new JMS Session
      Throws:
      JMSException - if thrown by JMS API methods
      See Also:

    • isClientAcknowledge

      protected boolean isClientAcknowledge(Session session) throws JMSException
      Determine whether the given Session is in client acknowledge mode.

      This implementation uses JMS 1.1 API.

      Parameters:
      session - the JMS Session to check
      Returns:
      whether the given Session is in client acknowledge mode
      Throws:
      JMSException - if thrown by JMS API methods
      See Also: