我不熟悉camel概念和activemq概念。这里我想使用嵌入式代理,并将其作为组件添加到camel上下文中。现在我想向activemq组件添加一些组件选项(例如 useSingleConnection=true
这不是端点选项,而是组件选项)。我知道这可以通过使用springxml来实现。有没有办法通过编程来实现这一点?
@Override
public void configure() throws Exception {
BrokerService broker = new BrokerService();
broker.addConnector("tcp://localhost:61213");
broker.setPersistent(true);
broker.start();
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(jmsProducerEndpointConfig.getBlindAddress());
//added componet to camle context
getContext().addComponent("test-jms", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
from("test-jms:queue:MyQueue?autoStartup=true&allowNullBody=false")
.process(exchange -> {
System.out.println(exchange.getIn().getBody());
}).to("file://test");
}
1条答案
按热度按时间ghhaqwfi1#
你发布的示例离你不远,下面的代码应该足够了: