Apache Camel - Filas de mensagens

A maioria dos projetos de integração usa mensagens, pois ajuda na criação de uma arquitetura de aplicativo fracamente acoplada. As mensagens podem ser síncronas ou assíncronas. JMS suporta ambospoint-to-point e publish-subscribemodelos. Você usa umQueue para ponto a ponto e Topicpara um modelo publicar-assinar. Em uma plataforma Java, o JMS - Java Messaging Service fornece uma interface para um servidor de mensagens. O Apache activeMQ é um provedor JMS de código aberto. O Camel não é fornecido com um provedor JMS; no entanto, ele pode ser configurado para usar activeMQ. Para usar este componente, você precisa incluir os seguintes jars em seu projeto - activemq, camel-spring e camel-jms.

O seguinte trecho de código mostra como configurar o Camel para 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>

Aqui, o aplicativo Camel começará a escutar uma fila chamada orderQueue. A própria fila é configurada no servidor de mensagens activeMQ em execução no host local e listada na porta 61000. Assim que isso for feito, seu aplicativo pode enviar ou receber mensagens para esta fila de qualquer um dos terminais definidos em seu aplicativo.

Finalmente, é hora de colocar tudo junto em um projeto para obter uma compreensão mais profunda de como os aplicativos Camel são criados.