Class HttpDestination.TimeoutTask

  • All Implemented Interfaces:
    Destroyable
    Enclosing class:
    HttpDestination

    private class HttpDestination.TimeoutTask
    extends CyclicTimeout
    This class enforces the total timeout for exchanges that are still in the queue. The total timeout for exchanges that are not in the destination queue is enforced by HttpChannel.
    • Field Detail

      • nextTimeout

        private final java.util.concurrent.atomic.AtomicLong nextTimeout
    • Constructor Detail

      • TimeoutTask

        private TimeoutTask​(Scheduler scheduler)
    • Method Detail

      • schedule

        private void schedule​(long expiresAt)