无法在Camelendpoint中设置ActiveMQ目标选项

Question

我正在尝试在驼峰JMS（ActiveMQ）使用者上设置预回迁策略。根据Camel文件http://camel.apache.org/activemq.html#ActiveMQ-使用ActiveMQDestinationOptions，我应该能够通过添加来实现这一点？目的地消费者到endpointURL的预取大小=1。

不幸的是，当我这样做时，我得到以下异常

Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: activemq://queue:ToSynchronize?destination.consumer.prefetchSize=1 due to: There are 1 parameters that couldn't be set on the endpoint. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown parameters=[{destination.consumer.prefetchSize=1}]
    at org.apache.camel.impl.DefaultComponent.validateParameters(DefaultComponent.java:183)
    at org.apache.camel.impl.DefaultComponent.createEndpoint(DefaultComponent.java:128)
    at org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:558)
    ... 48 more

我有一个简单的路线构建器

@Component
public class IntegrationRout extends RouteBuilder {

    @Override
    public void configure() throws Exception {
        from("activemq:queue:ToSynchronize?destination.consumer.prefetchSize=1")
            .unmarshal().jaxb("com.foo.jms.model")
            .beanRef("Service", "upload")
    }
}

以及Java中的Spring配置（摘自一些关于如何配置JMS事务客户端的教程）

@Configuration
@EnableTransactionManagement
@ComponentScan(basePackages = {"com.foo"})
public class SynchronizationConfiguration extends CamelConfiguration {

    @Bean
    public ConnectionFactory jmsConnectionFactory() {
        return new ActiveMQConnectionFactory("tcp://localhost:61616");
    }

    @Bean
    @Autowired
    public PlatformTransactionManager jmsTransactionManager(final ConnectionFactory jmsConnectionFactory) {
        return new JmsTransactionManager(jmsConnectionFactory);
    }

    @Bean
    @Autowired
    public JmsComponent activemq(final ConnectionFactory jmsConnectionFactory, final PlatformTransactionManager jmsTransactionManager) {
        return JmsComponent.jmsComponentTransacted(jmsConnectionFactory, jmsTransactionManager);
    }
}




Answer 1

匿名用户

如果配置ActiveMQ目标选项，如<代码>？目的地消费者prefetchSize=1必须显式使用ActiveMQComponent类。使用常规JmsComponent将不起作用。

所以你必须更换

    @Bean
    @Autowired
    public JmsComponent activemq(final ConnectionFactory jmsConnectionFactory, final PlatformTransactionManager jmsTransactionManager) {
        return JmsComponent.jmsComponentTransacted(jmsConnectionFactory, jmsTransactionManager);
    }

用类似的东西

    @Bean
    @Autowired
    public JmsComponent activemq(final ConnectionFactory jmsConnectionFactory, final PlatformTransactionManager jmsTransactionManager) {
        final ActiveMQComponent activemq = new ActiveMQComponent();
        activemq.setConnectionFactory(jmsConnectionFactory);
        activemq.setTransactionManager(jmsTransactionManager);
        activemq.setTransacted(true);
        return activemq;
    }