我使用Camel在RabbitMQ中消费和生成消息。另外,我正在使用Spring,所以我已经创建了一个ConnectionFactory bean,它具有我想要的所有配置。
这很好,但是我必须在我创建的每个端点字符串中声明bean的名称。
默认情况下,是否有办法设置camel来使用这个特定的bean?
发布于 2017-09-06 11:56:59
根据这些的消息来源,我不认为这是可以实现的。
发布于 2021-07-06 16:32:59
如果您将bean命名为rabbitConnectionFactory,则不必在每个端点中指定此名称。
例如:
@Bean
public ConnectionFactory rabbitConnectionFactory() {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
factory.setPort(5672);
factory.setUsername("guest");
factory.setPassword("guest");
return factory;
}在此之后,您的rabbitmq URI非常简单,如:public static final String RABBIT_URI = "rabbitmq:%s?queue=%s&routingKey=%s&autoDelete=false";
https://stackoverflow.com/questions/46071359
复制相似问题