client/src/main/java/io/hoplin/ConsumerErrorStrategy.java
/**
   * Create DLX exchange name
   *
   * @param exchangeName
   * @return
   */
Create DLX exchange name
@param exchangeName
@return
Create DLX exchange name @param exchangeName @return
static String createDlqExchangeName(final String exchangeName) {
    if (true) {
      return DEFAULT_ERROR_EXCHANGE;
    }
    final String name =
        (exchangeName == null || exchangeName.isEmpty()) ? DEFAULT_ERROR_EXCHANGE : exchangeName;
    return String.format("%s.%s", "hoplin.dead", name);
  }
static String createDlqExchangeName ( final String exchangeName ) { if ( true ) { return DEFAULT_ERROR_EXCHANGE ; } final String name = ( exchangeName == null || exchangeName . isEmpty ( ) ) ? DEFAULT_ERROR_EXCHANGE : exchangeName ; return String . format ( "%s.%s" , "hoplin.dead" , name ) ; }
Create DLX exchange name
 @param exchangeName
 @return
Create DLX exchange name @param exchangeName @return
// TODO : this should be controlled via a policy