eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/client/RabbitmqClient.java [137:145]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void closeChannel(Channel channel) {
        if (channel != null) {
            try {
                channel.close();
            } catch (Exception ex) {
                log.error("[RabbitmqClient] channel close happen exception.", ex);
            }
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/client/RabbitmqClient.java [137:145]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void closeChannel(Channel channel) {
        if (channel != null) {
            try {
                channel.close();
            } catch (Exception ex) {
                log.error("[RabbitmqClient] channel close happen exception.", ex);
            }
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -