client/src/main/java/io/hoplin/ExchangeClient.java
/**
   * Create instance of {@link ExchangeClient}
   *
   * @param options the connection options
   * @param binding the binding to use
   * @return
   */
Create instance of  ExchangeClient
@param options the connection options
@param binding the binding to use
@return
Create instance of ExchangeClient @param options the connection options @param binding the binding to use @return
static ExchangeClient create(final RabbitMQOptions options, final Binding binding) {
    final String exchange = binding.getExchange();
    switch (ExchangeType.fromValue(exchange)) {
      case DIRECT:
        return DirectExchangeClient.create(options, binding);
      case FANOUT:
        return FanoutExchangeClient.create(options, binding);
      case TOPIC:
        return TopicExchangeClient.create(options, binding);
      case HEADER:
        return HeaderExchangeClient.create(options, binding);
    }
    throw new HoplinRuntimeException("Unhandled exchange type : " + exchange);
  }
static ExchangeClient create ( final RabbitMQOptions options , final Binding binding ) { final String exchange = binding . getExchange ( ) ; switch ( ExchangeType . fromValue ( exchange ) ) { case DIRECT : return DirectExchangeClient . create ( options , binding ) ; case FANOUT : return FanoutExchangeClient . create ( options , binding ) ; case TOPIC : return TopicExchangeClient . create ( options , binding ) ; case HEADER : return HeaderExchangeClient . create ( options , binding ) ; } throw new HoplinRuntimeException ( "Unhandled exchange type : " + exchange ) ; }
Create instance of {@link ExchangeClient}
 @param options the connection options
 @param binding the binding to use
 @return
Create instance of { @link ExchangeClient } @param options the connection options @param binding the binding to use @return