Class AmqpInactivityMonitor

    • Constructor Detail

      • AmqpInactivityMonitor

        public AmqpInactivityMonitor​(Transport next,
                                     WireFormat wireFormat)
    • Method Detail

      • setAmqpTransport

        public void setAmqpTransport​(AmqpTransport amqpTransport)
      • startConnectionTimeoutChecker

        public void startConnectionTimeoutChecker​(long connectionTimeout)
      • startKeepAliveTask

        public void startKeepAliveTask​(long nextKeepAliveCheck)
        Starts the keep alive task which will run after the given delay.
        Parameters:
        nextKeepAliveCheck - time in milliseconds to wait before performing the next keep-alive check.
      • stopConnectionTimeoutChecker

        public void stopConnectionTimeoutChecker()
      • stopKeepAliveTask

        public void stopKeepAliveTask()