client/src/main/java/io/hoplin/rpc/RpcCallerConsumer.java
/**
   * Bind new message to specific {@link CompletableFuture}
   *
   * @param correlationId the id to bind reply message to
   * @param promise       the future to complete
   */
Bind new message to specific  CompletableFuture
@param correlationId the id to bind reply message to
@param promise       the future to complete
Bind new message to specific CompletableFuture @param correlationId the id to bind reply message to @param promise the future to complete
public void bind(final String correlationId, final CompletableFuture<?> promise) {
    Objects.requireNonNull(correlationId);
    Objects.requireNonNull(promise);
    bindings.put(correlationId, promise);
  }
public void bind ( final String correlationId , final CompletableFuture < ? > promise ) { Objects . requireNonNull ( correlationId ) ; Objects . requireNonNull ( promise ) ; bindings . put ( correlationId , promise ) ; }
Bind new message to specific {@link CompletableFuture}
 @param correlationId the id to bind reply message to
 @param promise       the future to complete
Bind new message to specific { @link CompletableFuture } @param correlationId the id to bind reply message to @param promise the future to complete