code: 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");
          }
  
      }
docs: Closes RabbitMQ channel and connection