带有spring-boot的Apache-camel答案

【问题标题】：Apache-camel with spring-boot带有spring-boot的Apache-camel
【发布时间】：2016-04-20 11:22:49
【问题描述】：

我正在尝试建立一个标题为堆栈的项目，我们使用的 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: 错误创建类中定义的名称为“jmsListenerContainerFactory”的bean 路径资源 [org/springframework/boot/autoconfigure/jms/JmsAnnotationDrivenConfiguration.class]：通过工厂方法实例化 Bean 失败；嵌套异常是 org.springframework.beans.BeanInstantiationException：失败实例化 [org.springframework.jms.config.DefaultJmsListenerContainerFactory]：工厂方法“jmsListenerContainerFactory”抛出异常；嵌套的例外是 java.lang.NoSuchMethodError： org.springframework.jms.config.DefaultJmsListenerContainerFactory.setAutoStartup(Z)V

在此先表示感谢，并对任何有问题的错误表示歉意。

【问题讨论】：

你试过camel spring boot包吗？这很简单，请查看 github.com/vivek-dhayalan/camel_cxfrs_spring_boot_java_dsl 以获取带有弹簧靴的示例，如果有帮助请告诉我。
一个很好的例子 Vivek 一起使用 spring boot 和 Camel - 我喜欢这样。
我试过了，但不符合我的需要。但这是一个很好的例子。

标签： spring-boot jms apache-camel activemq

【解决方案1】：

显然这是spring boot 1.3.3的一个bug： DefaultJmsListenerContainerFactory 不包含所需的方法。尝试升级到 spring boot 1.4.0（尽管它目前不在 RELEASE 版本中）。这应该可以解决错误。

【讨论】：

您是否能够通过升级到 Spring Boot 1.4.0 来解决此问题？我找不到 1.4.0.M1 或 M2 版本的 Maven 依赖项。你能帮我做同样的事情吗？

【解决方案2】：

我遇到了同样的异常并在这里阅读了答案。因为我使用的是 Spring boot 1.5.1-RELEASE，所以我发现答案不适用并继续搜索。我发现最终的原因是没有正确阅读手册： 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>

我希望它对某人有所帮助。

【讨论】：

【解决方案3】：

如果有人遇到这个问题，我找到了解决方案。

我们需要将spring-boot的版本降级到1.2.3.RELEASE，因为camel-jms:2.16.2使用的是4.1.9版本的spring组件。

【讨论】：