Class JmsConnector

    • Field Detail

      • NAMED_FACTORY_ATTRIBUTE

        protected static final String NAMED_FACTORY_ATTRIBUTE
        Select in case factory is injected as a named bean or configured with name.
        See Also:
        Constant Field Values
      • USERNAME_ATTRIBUTE

        protected static final String USERNAME_ATTRIBUTE
        User name used with ConnectionFactory.
        See Also:
        Constant Field Values
      • PASSWORD_ATTRIBUTE

        protected static final String PASSWORD_ATTRIBUTE
        Password used with ConnectionFactory.
        See Also:
        Constant Field Values
      • CLIENT_ID_ATTRIBUTE

        protected static final String CLIENT_ID_ATTRIBUTE
        Client identifier for JMS connection.
        See Also:
        Constant Field Values
      • DURABLE_ATTRIBUTE

        protected static final String DURABLE_ATTRIBUTE
        True for creating durable consumer (only for topic).
        See Also:
        Constant Field Values
      • SUBSCRIBER_NAME_ATTRIBUTE

        protected static final String SUBSCRIBER_NAME_ATTRIBUTE
        Subscriber name for durable consumer used to identify subscription.
        See Also:
        Constant Field Values
      • NON_LOCAL_ATTRIBUTE

        protected static final String NON_LOCAL_ATTRIBUTE
        If true then any messages published to the topic using this session's connection, or any other connection with the same client identifier, will not be added to the durable subscription.
        See Also:
        Constant Field Values
    • Constructor Detail

      • JmsConnector

        @Inject
        protected JmsConnector​(Config config,
                               Instance<javax.jms.ConnectionFactory> connectionFactories)
        Create new JmsConnector.
        Parameters:
        connectionFactories - connection factory beans
        config - root config for thread context
      • JmsConnector

        protected JmsConnector​(Map<String,​javax.jms.ConnectionFactory> connectionFactoryMap,
                               ScheduledExecutorService scheduler,
                               ExecutorService executor)
        Create new JmsConnector.
        Parameters:
        connectionFactoryMap - custom connection factories
        scheduler - custom scheduler for polling
        executor - custom executor for async tasks