如何在Spring RabbitMQ项目中使用多个虚拟主机？

debugcn 发表于 Dev

海夫拉斯（Stef Heyenrath）

我有以下两个配置类：

@Configuration
@EnableRabbit
@Import({ LocalRabbitConfigA.class, CloudRabbitConfigA.class })
public class RabbitConfigA {
    @Autowired
    @Qualifier("rabbitConnectionFactory_A")
    private ConnectionFactory rabbitConnectionFactory;

    @Bean(name = "admin_A")
    AmqpAdmin amqpAdmin() {
        return new RabbitAdmin(rabbitConnectionFactory);
    }

    @Bean(name = "Exchange_A")
    DirectExchange receiverExchange() {
        return new DirectExchange("Exchange_A", true, false);
    }
}

和

@Configuration
@EnableRabbit
@Import({ LocalRabbitConfigB.class, CloudRabbitConfigB.class })
public class RabbitConfigB {
    @Autowired
    @Qualifier("rabbitConnectionFactory_B")
    private ConnectionFactory rabbitConnectionFactory;

    @Bean(name = "admin_B")
    AmqpAdmin amqpAdmin() {
        return new RabbitAdmin(rabbitConnectionFactory);
    }

    @Bean(name = "Exchange_B")
    DirectExchange receiverExchange() {
        return new DirectExchange("Exchange_B", true, false);
    }
}

请注意，LocalRabbitConfigA和LocalRabbitConfigB类定义了连接到不同VHost的connectionFactory。
启动应用程序时（在Tomcat中），所有Exchange均在两个VHost中创建。

问题是如何定义由特定ConnectionFactiory创建的特定Exchange /队列？

这样VHost A仅包含Exchange_A，而VHost B仅包含Exchange_B？

加里·罗素

请参阅条件声明。

具体来说：

@Bean(name = "Exchange_B")
DirectExchange receiverExchange() {
    DirectExchange exchange = new DirectExchange("Exchange_B", true, false);
    exchange.setAdminsThatShouldDeclare(amqpAdmin());
    return exchange;
}

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。