eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/client/RabbitmqClient.java [87:99]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void binding(Channel channel, BuiltinExchangeType builtinExchangeType,
        String exchangeName, String routingKey, String queueName) {
        try {
            channel.exchangeDeclare(exchangeName, builtinExchangeType.getType(), true,
                false, false, null);
            channel.queueDeclare(queueName, false, false,
                false, null);
            routingKey = builtinExchangeType.getType().equals(BuiltinExchangeType.FANOUT.getType()) ? "" : routingKey;
            channel.queueBind(queueName, exchangeName, routingKey);
        } catch (Exception ex) {
            log.error("[RabbitmqClient] binding happen exception.", ex);
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/client/RabbitmqClient.java [87:99]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void binding(Channel channel, BuiltinExchangeType builtinExchangeType,
        String exchangeName, String routingKey, String queueName) {
        try {
            channel.exchangeDeclare(exchangeName, builtinExchangeType.getType(), true,
                false, false, null);
            channel.queueDeclare(queueName, false, false,
                false, null);
            routingKey = builtinExchangeType.getType().equals(BuiltinExchangeType.FANOUT.getType()) ? "" : routingKey;
            channel.queueBind(queueName, exchangeName, routingKey);
        } catch (Exception ex) {
            log.error("[RabbitmqClient] binding happen exception.", ex);
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -