client/src/main/java/io/hoplin/rpc/DefaultRpcServer.java
/**
   * Declare the request queue where the responder will be waiting for the RPC requests Create a
   * temporary, private, autodelete reply queue
   */
Declare the request queue where the responder will be waiting for the RPC requests Create a
temporary, private, autodelete reply queue
Declare the request queue where the responder will be waiting for the RPC requests Create a temporary private autodelete reply queue
private void bind() {
    log.info("Param RoutingKey  : {}", routingKey);
    log.info("Param Exchange    : {}", exchange);
    log.info("Param Request     : {}", requestQueueName);
    try {
      channel.exchangeDeclare(exchange, "direct", false, true, null);
      channel.queueDeclare(requestQueueName, false, false, true, null);
    } catch (final Exception e) {
      throw new HoplinRuntimeException("Unable to bind queue", e);
    }
  }
private void bind ( ) { log . info ( "Param RoutingKey  : {}" , routingKey ) ; log . info ( "Param Exchange    : {}" , exchange ) ; log . info ( "Param Request     : {}" , requestQueueName ) ; try { channel . exchangeDeclare ( exchange , "direct" , false , true , null ) ; channel . queueDeclare ( requestQueueName , false , false , true , null ) ; } catch ( final Exception e ) { throw new HoplinRuntimeException ( "Unable to bind queue" , e ) ; } }
Declare the request queue where the responder will be waiting for the RPC requests Create a
 temporary, private, autodelete reply queue
Declare the request queue where the responder will be waiting for the RPC requests Create a temporary private autodelete reply queue