client/src/main/java/io/hoplin/FanoutExchangeClient.java
/**
   * Create new {@link FanoutExchangeClient} client, this will create default RabbitMQ queues.
   *
   * @param options  the connection options to use
   * @param exchange the exchange to use
   * @return
   */
Create new  FanoutExchangeClient client, this will create default RabbitMQ queues.
@param options  the connection options to use
@param exchange the exchange to use
@return
Create new FanoutExchangeClient client this will create default RabbitMQ queues . @param options the connection options to use @param exchange the exchange to use @return
public static ExchangeClient create(final RabbitMQOptions options, final String exchange) {
    Objects.requireNonNull(options);
    Objects.requireNonNull(exchange);
    final Binding binding = BindingBuilder
        .bind()
        .to(new FanoutExchange(exchange));
    return create(options, binding);
  }
public static ExchangeClient create ( final RabbitMQOptions options , final String exchange ) { Objects . requireNonNull ( options ) ; Objects . requireNonNull ( exchange ) ; final Binding binding = BindingBuilder . bind ( ) . to ( new FanoutExchange ( exchange ) ) ; return create ( options , binding ) ; }
Create new {@link FanoutExchangeClient} client, this will create default RabbitMQ queues.
Create new { @link FanoutExchangeClient } client this will create default RabbitMQ queues .
// Producer does not bind to the queue only to the exchange when using FanoutExchange