Apache Camel - Files d'attente de messages

La plupart des projets d'intégration utilisent la messagerie car elle aide à créer une architecture d'application faiblement couplée. La messagerie peut être synchrone ou asynchrone. JMS prend en charge les deuxpoint-to-point et publish-subscribedes modèles. Vous utilisez unQueue pour point à point et Topicpour un modèle de publication-abonnement. Sur une plate-forme Java, JMS - Java Messaging Service fournit une interface avec un serveur de messagerie. Apache activeMQ est l'un de ces fournisseurs JMS open source. Camel n'est pas livré avec un fournisseur JMS; cependant, il peut être configuré pour utiliser activeMQ. Pour utiliser ce composant, vous devez inclure les fichiers JAR suivants dans votre projet - activemq, camel-spring et camel-jms.

L'extrait de code suivant montre comment configurer Camel pour activeMQ.

<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>

Ici, l'application Camel commencera à écouter une file d'attente appelée orderQueue. La file d'attente elle-même est configurée dans le serveur de messagerie activeMQ s'exécutant sur l'hôte local et répertoriant sur le port 61000. Une fois que cela est fait, votre application peut envoyer ou recevoir un message à cette file d'attente à partir de n'importe lequel des points de terminaison définis dans votre application.

Enfin, il est maintenant temps de tout rassembler dans un projet pour mieux comprendre comment les applications Camel sont créées.