client/src/main/java/io/hoplin/DefaultRabbitConnectionProvider.java
/**
   * Create and decorate our channel for possible reconnect
   *
   * @return
   * @throws IOException
   */
Create and decorate our channel for possible reconnect
@return
@throws IOException
Create and decorate our channel for possible reconnect @return @throws IOException
private Channel createChannel() throws IOException {
    final Channel channel = connection.createChannel();
    channel.addShutdownListener(sse -> {
      if (sse.isInitiatedByApplication()) {
        log.info("Channel #{} closed.", channel.getChannelNumber());
      } else {
        log.info("Channel #{} suddenly closed.", channel.getChannelNumber());
        log.error("Channel closed", sse);
      }
    });
    return channel;
  }
private Channel createChannel ( ) throws IOException { final Channel channel = connection . createChannel ( ) ; channel . addShutdownListener ( sse -> { if ( sse . isInitiatedByApplication ( ) ) { log . info ( "Channel #{} closed." , channel . getChannelNumber ( ) ) ; } else { log . info ( "Channel #{} suddenly closed." , channel . getChannelNumber ( ) ) ; log . error ( "Channel closed" , sse ) ; } } ) ; return channel ; }
Create and decorate our channel for possible reconnect
 @return
 @throws IOException
Create and decorate our channel for possible reconnect @return @throws IOException