Apache Camel - Code di messaggi

La maggior parte dei progetti di integrazione utilizza la messaggistica in quanto aiuta a creare un'architettura applicativa liberamente accoppiata. La messaggistica può essere sincrona o asincrona. JMS supporta entrambipoint-to-point e publish-subscribeModelli. Usi un fileQueue per punto a punto e Topicper un modello di pubblicazione-sottoscrizione. Su una piattaforma Java, JMS - Java Messaging Service fornisce un'interfaccia a un server di messaggistica. Apache activeMQ è uno di questi provider JMS open source. Camel non viene spedito con un provider JMS; tuttavia, può essere configurato per utilizzare activeMQ. Per utilizzare questo componente, devi includere i seguenti barattoli nel tuo progetto: activemq, camel-spring e camel-jms.

Il seguente frammento di codice mostra come configurare Camel per 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>

Qui, l'applicazione Camel inizierà ad ascoltare una coda chiamata orderQueue. La coda stessa viene configurata nel server di messaggistica activeMQ in esecuzione sull'host locale e viene elencata sulla porta 61000. Una volta eseguita questa operazione, l'applicazione può inviare o ricevere messaggi a questa coda da uno qualsiasi degli endpoint definiti nell'applicazione.

Infine, è giunto il momento di mettere tutto insieme in un progetto per ottenere una comprensione più profonda di come vengono create le applicazioni Camel.