Class OutstandingRequests


  • public class OutstandingRequests
    extends java.lang.Object
    • Field Detail

      • lock

        private java.util.concurrent.locks.ReentrantReadWriteLock lock
      • lookup

        private java.util.Map<java.lang.Long,​Request> lookup
      • cancelLookup

        private java.util.Map<java.util.UUID,​Request> cancelLookup
    • Constructor Detail

      • OutstandingRequests

        public OutstandingRequests()
    • Method Detail

      • isOutstanding

        public boolean isOutstanding​(java.lang.Long messageId)
      • getRequestByMessageId

        public Request getRequestByMessageId​(java.lang.Long messageId)
      • getRequestByCancelId

        Request getRequestByCancelId​(java.util.UUID cancelId)
      • receivedResponseFor

        public Request receivedResponseFor​(java.lang.Long messageId)
      • registerOutstanding

        void registerOutstanding​(Request request)
      • handleError

        void handleError​(java.lang.Throwable t)