Class LeaseRequest<T,​C,​E extends PoolEntry<T,​C>>

    • Field Detail

      • route

        private final T route
      • state

        private final java.lang.Object state
      • connectTimeout

        private final long connectTimeout
      • deadline

        private final long deadline
      • sessionRequestRef

        private final java.util.concurrent.atomic.AtomicReference<SessionRequest> sessionRequestRef
      • completed

        private final java.util.concurrent.atomic.AtomicBoolean completed
      • result

        private volatile E extends PoolEntry<T,​C> result
      • ex

        private volatile java.lang.Exception ex
    • Constructor Detail

      • LeaseRequest

        public LeaseRequest​(T route,
                            java.lang.Object state,
                            long connectTimeout,
                            long leaseTimeout,
                            BasicFuture<E> future)
        Contructor
        Parameters:
        route - route
        state - state
        connectTimeout - http connection timeout
        leaseTimeout - timeout to wait in a request queue until kicked off
        future - future callback
    • Method Detail

      • getRoute

        public T getRoute()
      • getState

        public java.lang.Object getState()
      • getConnectTimeout

        public long getConnectTimeout()
      • getDeadline

        public long getDeadline()
      • isDone

        public boolean isDone()
      • attachSessionRequest

        public void attachSessionRequest​(SessionRequest sessionRequest)
      • cancel

        public boolean cancel()
        Description copied from interface: Cancellable
        Cancels the ongoing operation or process.
        Specified by:
        cancel in interface Cancellable
        Returns:
        true if the operation or process has been cancelled as a result of this method call or false if it has already been cancelled or not started.
      • failed

        public void failed​(java.lang.Exception ex)
      • completed

        public void completed​(E result)
      • getResult

        public E getResult()
      • getException

        public java.lang.Exception getException()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object