如何在侦听器使用CAMEL接收JMS消息之前延迟队列中的JMS消息？

Question

<bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
    <property name="connectionFactory" ref="jmsConnectionFactory" />
</bean>

<camelContext id="camelContext" xmlns="http://camel.apache.org/schema/spring">  

    <route id="routeOne" delayer="10000">               
        <from uri="jms://queueone?concurrentConsumers=1"/>          
        <log message="routeOne incoming message ${body}"/>              
        <delay><constant>30000</constant></delay>                       
        <process ref="loggerProcessor"/>                        
    </route>

</camelContext> 

<bean id="loggerProcessor" name="loggerProcessor" class="emh.LoggerProcessor"/>

Answer 1

Camel delay和throttle将从ActiveMQ队列中删除（消耗）消息，并将其保留在路由中（内存中），直到处理完毕。事务JMS可能会缓解与丢失消息有关的问题，但还没有尝试过。发人深省。

我使用AMQ_scheduled_delay标头和启用schedulersupport[1,2,3,4,5,6]使它在Spring Boot2中与Camel和ActiveMQ一起工作。这是每个JMS2.0交付延迟。

请注意，只有当没有活动使用者时，消息才会出现在ActiveMQ队列（挂起）中，即应用程序关闭或Camel路由禁用。下面的配置用于使用现有的ActiveMQ代理。

spring.activemq.broker-url=tcp://localhost:61616

from("jms://incomingQueue").setHeader("AMQ_SCHEDULED_DELAY", constant("1000")).inOnly("jms://delayedQueue");  

from("jms://delayedQueue").process(...);

xml（现有的代理安装）

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}" schedulerSupport="true">  

在/usr/local/cellar/activemq/ /libexec/conf 下找到OSX自制程序。

如果希望使用嵌入在应用程序中的代理，可以使用BrokerService。

@Bean
public BrokerService brokerService()
{
    BrokerService brokerService = new BrokerService();
    brokerService.setSchedulerSupport( true );
    return brokerService;
}