如何使用Apache Camel中的端點消息？

我創建了一個包含主題名稱的消息，並使用鍵/值對設置了一些信息並將消息發送到MessageBus（即，將消息生成爲一個endPoint--在我的案例中，endpoint是一個messageBus）。如何使用Apache Camel中的端點消息？

如何消耗該終點的消息？我知道uri，終點。我的客戶需要完成哪些配置（任何駱駝XML更改要完成？）。

請幫忙。

來源

2011-12-23 Karthik kumar

註冊被刪除，請參見常見問題的http：//小號tackoverflow.com/faq#signatures – 2011-12-23 14:20:06

你可以發佈你現有的路由定義嗎？ – 2011-12-23 18:06:00

我的路由定義是test-proxy - > text-bus。該消息是到達文本總線，這是一個activeMq。我需要編寫一個消費者從activeMq（它是端點）讀取此消息。 – 2011-12-26 06:16:16

看到camel-jms頁的詳細信息，但基本上需要做一些基本的Spring XML配置ActiveMQ的連接，然後建立你的路線......

from("activemq:queue:inboundQueue").bean(MyConsumerBean.class); 

<bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent"> 
    <property name="connectionFactory"> 
     <bean class="org.apache.activemq.ActiveMQConnectionFactory"> 
      <property name="brokerURL" value="vm://localhost?broker.persistent=false&broker.useJmx=false"/> 
     </bean> 
    </property> 
</bean>

看到這些單元測試的更多信息.. 。

https://svn.apache.org/repos/asf/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteTest.java

https://svn.apache.org/repos/asf/camel/trunk/components/camel-jms/src/test/resources/org/apache/camel/component/jms/jmsRouteUsingSpring.xml

來源

2012-01-23 17:03:24

如何使用Apache Camel中的端點消息？

回答

相關問題