public void deinit ( ) { if ( channel != null ) try { channel . close ( ) ; } catch ( IOException | TimeoutException e ) { log . warn ( "Failed to close channel in RabbitMQ connector" ) ; } if ( connection != null ) try { connection . close ( ) ; } catch ( IOException e ) { log . warn ( "Failed to close connection in RabbitMQ connector" ) ; } }
Closes RabbitMQ channel and connection