带Spring Boot的Apache-camel

Question

我正在尝试用title上的堆栈建立一个项目，我们正在使用的JMS是ActiveMQ。下面是我正在进行的配置：

@SpringBootApplication

public class Application {

private static Logger logger = Logger.getLogger(Application.class);

@Value("${broker.component.name}")
private String brokerComponetName;
@Value("${broker.dead.letter.queue}")
private String brokerDeadLetterQueue;
@Value("${broker.in.queue}")
private String brokerInQueue;
@Value("${broker.out.queue}")
private String brokerOutQueue;
@Value("${broker.url}")
private String brokerUrl;
@Value("${broker.user}")
private String brokerUser;
@Value("${broker.password}")
private String brokerPassword;

public static void main(String[] args) throws Exception {
    logger.info("starting loader");
    SpringApplication.run(Application.class, args);
}

@Bean
public SpringCamelContext camelContext(ApplicationContext applicationContext) throws Exception {

    SpringCamelContext camelContext = new SpringCamelContext(applicationContext);

    camelContext.addComponent(brokerComponetName, JmsComponent.jmsComponent(connectionFactory()));

    camelContext.addRoutes(new RouteBuilder() {
        public void configure() throws ConfigurationException {
            errorHandler(deadLetterChannel(brokerDeadLetterQueue)
                    .onRedelivery(new FailureProcessor())
                    .useOriginalMessage()
                    .maximumRedeliveries(5)
                    .redeliveryDelay(5000)
                    .retryAttemptedLogLevel(LoggingLevel.INFO));

            from(brokerInQueue)
                .process(new MessageProcessor())
                .to(brokerOutQueue);
        }
    });

    return camelContext;
}

@Bean
public ConnectionFactory connectionFactory() throws ConfigurationException {
    System.out.println("BROKER URL: " + brokerUrl);
    return new ActiveMQConnectionFactory(brokerUser,
            brokerPassword, brokerUrl);
}

我已经尝试将@enablejms添加到应用程序中，但没有成功。堆栈错误如下：

org.springframework.beans.factory.beanCreationException：创建类路径资源[org/springframework/boot/autoconfigure/jms/jmsanNotationDrivenConfiguration.class]中定义的名为“JMS ListenerContainerFactory”的bean时出错：通过工厂方法实例化bean失败；嵌套异常为org.springframework.beans.beanInstantiationException：实例化[org.springframework.jms.config.defaultJMSListenerContainerFactory]失败：工厂方法“jms ListenerContainerFactory”引发异常；嵌套异常为java.lang.NoSuchMethodError：org.springframework.jms.config.defaultJMSListenerContainerFactory.setAutoStartup(Z)V

谢谢你的提前和抱歉任何错误的问题。

Answer 1

我遇到了同样的例外，在这里读到了答案。因为我使用的是spring boot 1.5.1版，我发现答案不适用，于是继续搜索。我发现原因是没有正确阅读手册：http://camel.apache.org/activemq.html。导言指出：

要使用该组件，请确保类路径上有activeMQ.jar或activeMQ-core.jar以及任何Camel依赖项，如camel-core.jar、camel-spring.jar和camel-jms.jar。

所以解决这个问题的是2个额外的Maven条目。

<dependency>
  <groupId>org.apache.camel</groupId>
  <artifactId>camel-spring</artifactId>
  <version>${apache.camel.version}</version>
</dependency>
<dependency>
  <groupId>org.apache.camel</groupId>
  <artifactId>camel-jms</artifactId>
  <version>${apache.camel.version}</version>
</dependency>

我希望它能帮到某人。

Answer 2

显然这是spring boot 1.3.3的一个bug:DefaultJmsListenerContainerFactory不包含所需的方法。尝试升级到spring boot 1.4.0（尽管目前还没有发布版本）。这样就可以解决这个问题了。