Class OutboundTopicConnectionFactory

  • All Implemented Interfaces:
    jakarta.jms.ConnectionFactory, jakarta.jms.TopicConnectionFactory, jakarta.resource.Referenceable, Serializable, Referenceable

    public class OutboundTopicConnectionFactory
    extends OutboundConnectionFactory
    implements jakarta.jms.TopicConnectionFactory
    An OutboundTopicConnectionFactory instance is used for getting a PubSub connection to an underlying JORAM server.
    See Also:
    Serialized Form
    • Field Detail

      • logger

        private static final Logger logger
      • DEBUG

        private static final boolean DEBUG
      • serialVersionUID

        private static final long serialVersionUID
        define serialVersionUID for interoperability
        See Also:
        Constant Field Values
    • Constructor Detail

      • OutboundTopicConnectionFactory

        OutboundTopicConnectionFactory​(ManagedConnectionFactoryImpl mcf,
                                       jakarta.resource.spi.ConnectionManager cxManager)
        Constructs an OutboundTopicConnectionFactory instance.
        Parameters:
        mcf - Central manager for outbound connectivity.
        cxManager - Manager for connection pooling.
    • Method Detail

      • createTopicConnection

        public jakarta.jms.TopicConnection createTopicConnection()
                                                          throws jakarta.jms.JMSException
        Requests a PubSub connection for the default user, eventually returns an OutboundTopicConnection instance.
        Specified by:
        createTopicConnection in interface jakarta.jms.TopicConnectionFactory
        Throws:
        jakarta.jms.JMSSecurityException - If connecting is not allowed.
        jakarta.jms.IllegalStateException - If the underlying JORAM server is not reachable.
        jakarta.jms.JMSException - Generic exception.
      • createTopicConnection

        public jakarta.jms.TopicConnection createTopicConnection​(String userName,
                                                                 String password)
                                                          throws jakarta.jms.JMSException
        Requests a PubSub connection for a given user, eventually returns an OutboundConnection instance.
        Specified by:
        createTopicConnection in interface jakarta.jms.TopicConnectionFactory
        Throws:
        jakarta.jms.JMSSecurityException - If connecting is not allowed.
        jakarta.jms.IllegalStateException - If the underlying JORAM server is not reachable.
        jakarta.jms.JMSException - Generic exception.