在驼峰路由上使用自定义JMS侦听器的“containerFactory”

Question

我想使用骆驼路由接收消息，但能够以某种方式注入自定义“容器工厂”。

通常（没有骆驼路线），你会做以下事情：

@JmsListener(destination = "${some.virtual-topic.queue}", 
containerFactory = "customJmsListenerContainerFactory")
public void receiveMessage(String message) throws Exception {
  // do something cool with the received message ...
}

注意上面“JmsListener”注释的“containerFactory”属性如何为我们提供了一种使用非默认“containerFactory”的方法。这很好，但是如果我们想使用骆驼路径从队列中读取呢？类似于：

@Component
public class TestRoute extends RouteBuilder  {
    
    @Override
    public void configure() throws Exception {
        from("activemq:queue:{{some.virtual-topic.queue}}")
            .bean(MessageFacade.class, "process");
    } 
}

在上面的最新案例中，我无法“注入”自定义JMS containerFactory。有谁知道这是否可能（以非黑客的方式）？否则，我们将不得不依赖标准的听者。

Answer 1

请参阅文档：https://camel.apache.org/components/latest/activemq-component.html

选项consumerType应该设置为Custom，messageListenerContainerFactory应该引用容器工厂实现的bean id。