client/src/main/java/io/hoplin/TopicExchangeClient.java
/**
   * Create new {@link TopicExchangeClient}
   *
   * @param options  the connection options to use
   * @param exchange the exchange to use
   * @return
   */
Create new  TopicExchangeClient
@param options  the connection options to use
@param exchange the exchange to use
@return
Create new TopicExchangeClient @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);
    return create(options, createSensibleBindings(exchange, "", "#"));
  }
public static ExchangeClient create ( final RabbitMQOptions options , final String exchange ) { Objects . requireNonNull ( options ) ; Objects . requireNonNull ( exchange ) ; return create ( options , createSensibleBindings ( exchange , "" , "#" ) ) ; }
Create new {@link TopicExchangeClient}
 @param options  the connection options to use
 @param exchange the exchange to use
 @return
Create new { @link TopicExchangeClient } @param options the connection options to use @param exchange the exchange to use @return
// Producer does not bind to the queue only to the exchange when using TopicExchangeClient // no-routing key required for publishers, but in publish/subscribe mode we want get all messages