Apache-camel-message-queues

Apache Camel-メッセージキュー

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

次のコードスニペットは、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アプリケーションがどのように作成されるかをより深く理解するために、すべてをプロジェクトにまとめるときが来ました。