Class MQTopicConnection

All Implemented Interfaces:
JmsConnection, JmsPropertyContext, JmsReadablePropertyContext, JmsTopicConnection, jakarta.jms.Connection, jakarta.jms.TopicConnection, Serializable, AutoCloseable, Map<String,Object>
Direct Known Subclasses:
MQXATopicConnection

public class MQTopicConnection extends MQConnection implements jakarta.jms.TopicConnection, JmsTopicConnection
An MQTopicConnection object is an active connection to a publish/subscribe JMS provider.
See Also:
  • Method Details

    • createTopicSession

      public jakarta.jms.TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws jakarta.jms.JMSException
      Creates a TopicSession object.
      Specified by:
      createTopicSession in interface jakarta.jms.TopicConnection
      Parameters:
      transacted - if true, throws a JMSException on a real-time connection to a broker
      acknowledgeMode - indicates whether the consumer or the client will acknowledge any messages it receives; ignored if the session is transacted. Legal values are Session.AUTO_ACKNOWLEDGE, Session.CLIENT_ACKNOWLEDGE, and Session.DUPS_OK_ACKNOWLEDGE.
      Returns:
      a newly created topic session
      Throws:
      jakarta.jms.JMSException - if the connection failed to create a session due to an internal error or if a transacted session was requested when using a real-time connection to a broker