ApacheCamel-メッセージキュー

統合プロジェクトのほとんどは、疎結合のアプリケーションアーキテクチャの作成に役立つため、メッセージングを使用します。メッセージングは、同期または非同期のいずれかです。JMSは両方をサポートしますpoint-to-point そして publish-subscribeモデル。あなたはQueue ポイントツーポイントおよび Topicパブリッシュ/サブスクライブモデルの場合。Javaプラットフォームでは、JMS-Java MessagingServiceがメッセージングサーバーへのインターフェイスを提供します。Apache activeMQは、そのようなオープンソースのJMSプロバイダーの1つです。CamelにはJMSプロバイダーは付属していません。ただし、activeMQを使用するように構成できます。このコンポーネントを使用するには、プロジェクトに次のjarを含める必要があります-activemq、camel-spring、およびcamel-jms。

次のコードスニペットは、activeMQ用にCamelを構成する方法を示しています。

<bean id = "jms" class = "org.apache.camel.component.jms.JmsComponent">
   <property name = "connectionFactory">
      <bean class="org.apache.activemq.ActiveMQConnectionFactory">
         <property name = "orderQueue" value = "tcp://localhost:61000" />
      </bean>
   </property>
</bean>

ここで、Camelアプリケーションはと呼ばれるキューのリッスンを開始します orderQueue。キュー自体は、ローカルホストで実行され、ポート61000にリストされているactiveMQメッセージングサーバーにセットアップされます。これが完了すると、アプリケーションは、アプリケーションで定義された任意のエンドポイントからこのキューにメッセージを送受信できます。

最後に、Camelアプリケーションがどのように作成されるかをより深く理解するために、すべてをプロジェクトにまとめる時が来ました。