Class AqConfigBuilder

    • Method Detail

      • acknowledgeMode

        public AqConfigBuilder acknowledgeMode​(AcknowledgeMode acknowledgeMode)
        JMS acknowledgement mode.
        • AUTO_ACKNOWLEDGE Acknowledges automatically after message reception over JMS api.
        • CLIENT_ACKNOWLEDGE Message is acknowledged when Message.ack() is invoked either manually or by Acknowledgment policy.
        • DUPS_OK_ACKNOWLEDGE Messages are acknowledged lazily which can result in duplicate messages being delivered.
        • Type: enum
        • Default: AUTO_ACKNOWLEDGE
        • Valid Values: AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE
        Parameters:
        acknowledgeMode - AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE
        Returns:
        this builder
      • transacted

        public AqConfigBuilder transacted​(boolean transacted)
        Indicates whether the session will use a local transaction.
        • Type: boolean
        • Default: false
        • Valid Values: true, false
        Parameters:
        transacted - true if so
        Returns:
        this builder
      • username

        public AqConfigBuilder username​(String username)
        User name used for creating JMS connection.
        • Type: string
        Parameters:
        username - JMS connection user name
        Returns:
        this builder
      • password

        public AqConfigBuilder password​(String password)
        Password used for creating JMS connection.
        • Type: string
        Parameters:
        password - JMS connection password
        Returns:
        this builder
      • destination

        public AqConfigBuilder destination​(String destination)
        Queue or topic name.
        • Type: string
        Parameters:
        destination - queue or topic name
        Returns:
        this builder
      • queue

        public AqConfigBuilder queue​(String destination)
        Use supplied destination name and QUEUE as type.
        • Type: string
        Parameters:
        destination - queue name
        Returns:
        this builder
      • topic

        public AqConfigBuilder topic​(String destination)
        Use supplied destination name and TOPIC as type.
        • Type: string
        Parameters:
        destination - topic name
        Returns:
        this builder
      • messageSelector

        public AqConfigBuilder messageSelector​(String messageSelector)
        JMS API message selector expression based on a subset of the SQL92. Expression can only access headers and properties, not the payload.
        • Type: string
        • Example: NewsType = ’Sports’ OR NewsType = ’Opinion’
        Parameters:
        messageSelector - message selector expression
        Returns:
        this builder
      • pollTimeout

        public AqConfigBuilder pollTimeout​(long pollTimeout)
        Timeout for polling for next message in every poll cycle in millis.
        • Type: milliseconds
        • Default: 50
        Parameters:
        pollTimeout - timeout of polling for next message
        Returns:
        this builder
      • periodExecutions

        public AqConfigBuilder periodExecutions​(long periodExecutions)
        Period for executing poll cycles in millis.
        • Type: milliseconds
        • Default: 100
        Parameters:
        periodExecutions - period for executing poll cycles in millis
        Returns:
        this builder
      • sessionGroupId

        public AqConfigBuilder sessionGroupId​(String sessionGroupId)
        When multiple channels share same session-group-id, they share same JMS session.
        • Type: string
        Parameters:
        sessionGroupId - identifier for channels sharing same JMS session
        Returns:
        this builder