client/src/main/java/io/hoplin/batch/DefaultBatchClient.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() {
    if (replyToQueueName == null ||
        replyToQueueName.isEmpty() ||
        "amq.rabbitmq.reply-to".equalsIgnoreCase(replyToQueueName)) {
      replyToQueueName = "amq.rabbitmq.reply-to";
      directReply = true;
    } else {
      replyToQueueName = replyToQueueName + ".reply-to." + UUID.randomUUID();
    }
    log.info("Param Exchange, ReplyTo, directReply  : {}, {}, {}", exchange, replyToQueueName,
        directReply);
    try {
      if (!directReply) {
        channel.exchangeDeclare(exchange, "direct", true, false, null);
        channel.queueDeclare(replyToQueueName, false, false, true, null);
      }
    } catch (final Exception e) {
      throw new HoplinRuntimeException("Unable to bind queue", e);
    }
  }
private void bind ( ) { if ( replyToQueueName == null || replyToQueueName . isEmpty ( ) || "amq.rabbitmq.reply-to" . equalsIgnoreCase ( replyToQueueName ) ) { replyToQueueName = "amq.rabbitmq.reply-to" ; directReply = true ; } else { replyToQueueName = replyToQueueName + ".reply-to." + UUID . randomUUID ( ) ; } log . info ( "Param Exchange, ReplyTo, directReply  : {}, {}, {}" , exchange , replyToQueueName , directReply ) ; try { if ( ! directReply ) { channel . exchangeDeclare ( exchange , "direct" , true , false , null ) ; channel . queueDeclare ( replyToQueueName , 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