eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/client/RabbitmqClient.java [49:62]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public Connection getConnection(String host, String username,
        String passwd, int port,
        String virtualHost) throws Exception {
        ConnectionFactory factory = rabbitmqConnectionFactory.createConnectionFactory();
        factory.setHost(host.trim());
        factory.setPort(port);
        if (StringUtils.isNotEmpty(virtualHost)) {
            factory.setVirtualHost(virtualHost.trim());
        }
        factory.setUsername(username);
        factory.setPassword(passwd.trim());

        return rabbitmqConnectionFactory.createConnection(factory);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/client/RabbitmqClient.java [49:62]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public Connection getConnection(String host, String username,
        String passwd, int port,
        String virtualHost) throws Exception {
        ConnectionFactory factory = rabbitmqConnectionFactory.createConnectionFactory();
        factory.setHost(host.trim());
        factory.setPort(port);
        if (StringUtils.isNotEmpty(virtualHost)) {
            factory.setVirtualHost(virtualHost.trim());
        }
        factory.setUsername(username);
        factory.setPassword(passwd.trim());

        return rabbitmqConnectionFactory.createConnection(factory);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -