examples/src/main/java/examples/logtopic/ReceiveLogsTopic.java
/**
   * Creating client with binding allows us for more granular control of how Exchage
   *
   * @param exchange
   * @param queue
   * @param routingKey
   * @return
   */
Creating client with binding allows us for more granular control of how Exchage
@param exchange
@param queue
@param routingKey
@return
Creating client with binding allows us for more granular control of how Exchage @param exchange @param queue @param routingKey @return
private static ExchangeClient clientFromBinding(final String exchange, final String queue,
      final String routingKey) {
    final Binding binding = BindingBuilder
        .bind(queue)
        .to(new TopicExchange(exchange))
        .withAutoAck(true)
        .withPrefetchCount(1)
        .withPublisherConfirms(true)
        .with(routingKey)
        .build();
    return ExchangeClient.topic(options(), binding);
  }
private static ExchangeClient clientFromBinding ( final String exchange , final String queue , final String routingKey ) { final Binding binding = BindingBuilder . bind ( queue ) . to ( new TopicExchange ( exchange ) ) . withAutoAck ( true ) . withPrefetchCount ( 1 ) . withPublisherConfirms ( true ) . with ( routingKey ) . build ( ) ; return ExchangeClient . topic ( options ( ) , binding ) ; }
Creating client with binding allows us for more granular control of how Exchage
 @param exchange
 @param queue
 @param routingKey
 @return
Creating client with binding allows us for more granular control of how Exchage @param exchange @param queue @param routingKey @return