Class AbstractJmsContext

java.lang.Object
com.epam.fixengine.jms.context.AbstractJmsContext
All Implemented Interfaces:
JMSContext
Direct Known Subclasses:
JndiContext, SimpleJmsContext

public abstract class AbstractJmsContext extends Object implements JMSContext
  • Constructor Details

    • AbstractJmsContext

      public AbstractJmsContext(String userName, String password)
  • Method Details

    • createConnection

      public jakarta.jms.Connection createConnection() throws jakarta.jms.JMSException
      Creates the JMS Connection
      Specified by:
      createConnection in interface JMSContext
      Returns:
      Connection
      Throws:
      jakarta.jms.JMSException
    • getConfiguredDestination

      public jakarta.jms.Destination getConfiguredDestination(String destinationName, jakarta.jms.Session session, MessagingMode messagingMode) throws jakarta.jms.JMSException
      Creates JMS Destination
      Specified by:
      getConfiguredDestination in interface JMSContext
      Parameters:
      destinationName - the JMS destination identifier
      session - the JMS session
      messagingMode - mode: queue or topic
      Returns:
      Destination
      Throws:
      jakarta.jms.JMSException
    • createClientSession

      public jakarta.jms.Session createClientSession(com.epam.fixengine.jms.client.ConnectionImpl connection, boolean transacted) throws jakarta.jms.JMSException
      Creates the session.
      Specified by:
      createClientSession in interface JMSContext
      Parameters:
      connection - the connection
      Throws:
      jakarta.jms.JMSException
    • createClientSession

      public jakarta.jms.Session createClientSession(com.epam.fixengine.jms.client.ConnectionImpl connection, boolean transacted, int acknowledgeMode) throws jakarta.jms.JMSException
      Creates the session.
      Specified by:
      createClientSession in interface JMSContext
      Parameters:
      connection - the connection
      transacted - the flag
      acknowledgeMode - the
      Throws:
      jakarta.jms.JMSException
    • getConnectionFactory

      public abstract jakarta.jms.ConnectionFactory getConnectionFactory() throws jakarta.jms.JMSException
      Throws:
      jakarta.jms.JMSException