我将 Pojo 对象设置为处于战争中的队列(来自独立应用程序),然后在战争中我需要从队列中读取并处理对象。完成后,该对象设置为另一个队列(已处理队列)。战争期间发生的所有处理。所以会有另一个应用程序从已处理的队列中读取并处理对象。
那么处理这种情况的最佳方法是什么?我可以得到任何端到端的样本吗?
我将 Pojo 对象设置为处于战争中的队列(来自独立应用程序),然后在战争中我需要从队列中读取并处理对象。完成后,该对象设置为另一个队列(已处理队列)。战争期间发生的所有处理。所以会有另一个应用程序从已处理的队列中读取并处理对象。
那么处理这种情况的最佳方法是什么?我可以得到任何端到端的样本吗?
只需使用外部 JMS 代理 (ActiveMQ),每个应用程序都可以独立连接到该代理并从队列中生产/使用……这是一种标准/轻量级的方式来桥接应用程序与 JMS……
<!--APP1-->
<camelContext xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri="activemq:inQ" />
<to uri="bean:MyBean" />
<to uri="activemq:outQ" />
</route>
</camelContext>
<bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
<property name="brokerURL" value="tcp://somehost:61616"/>
</bean>
<!--APP2-->
<camelContext xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri="activemq:outQ" />
...
</route>
</camelContext>
<bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
<property name="brokerURL" value="tcp://somehost:61616"/>
</bean>
有关详细信息,请参阅此页面:http: //camel.apache.org/activemq.html