Class RabbitRpcClient.RabbitRpcRequest

  • All Implemented Interfaces:
    com.google.common.util.concurrent.ListenableFuture<byte[]>, Future<byte[]>
    Enclosing class:
    RabbitRpcClient

    protected static class RabbitRpcClient.RabbitRpcRequest
    extends com.google.common.util.concurrent.AbstractFuture<byte[]>
    implements Future<byte[]>
    Simple extension of the AbstractFuture class that waits for the response which is set by the setResponse(byte[] response).
    Author:
    Michael Röder (roeder@informatik.uni-leipzig.de)
    • Constructor Detail

      • RabbitRpcRequest

        protected RabbitRpcRequest()
    • Method Detail

      • setResponse

        public void setResponse​(byte[] response)
        Calls the internal set method of the AbstractFuture class.
        Parameters:
        response - the response this request is waiting for