2011-12-23 11 views
0

トピック名のメッセージを作成し、キーと値のペアで情報を設定し、メッセージをMessageBusに送信しました(つまり、endPointにメッセージを生成しました - 私のケースのエンドポイントはmessageBusです)。Apache Camelのエンドポイントからメッセージを消費するにはどうすればいいですか?

そのエンドポイントからのメッセージをどのように消費できますか?私は、エンドポイント、エンドポイントを知っています。私の消費者のためにどのような設定を行う必要がありますか?

助けてください。

+0

ログインが削除され、よくある質問のhttpを参照してください:// S tackoverflow.com/faq#signatures –

+1

既存のルート定義を投稿できますか? –

+0

私のルート定義はtest-proxy - > text-busです。メッセージはactiveMqであるテキストバス上に到着する。私は、エンドポイントであるactiveMqからこのメッセージを読む消費者を書く必要があります。 –

答えて

0

詳細はcamel-jmsページを参照していますが、基本的にはActiveMQの接続を設定するには、いくつかの基本的な春のXMLを行い、その後、あなたのルートを確立する必要があります...

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

関連する問題