Apache Camel - Mesaj Sıraları

Entegrasyon projelerinin çoğu, gevşek bağlı uygulama mimarisi oluşturmaya yardımcı olduğu için mesajlaşma kullanır. Mesajlaşma eşzamanlı veya eşzamansız olabilir. JMS her ikisini de desteklerpoint-to-point ve publish-subscribemodeller. BirQueue noktadan noktaya ve Topicbir yayınlama-abone olma modeli için. Bir Java platformunda, JMS - Java Messaging Service, bir mesajlaşma sunucusuna bir arayüz sağlar. Apache activeMQ böyle bir açık kaynak JMS sağlayıcısıdır. Camel, bir JMS sağlayıcısı ile birlikte gönderilmez; ancak, activeMQ kullanacak şekilde yapılandırılabilir. Bu bileşeni kullanmak için, projenize şu kavanozları eklemeniz gerekir - activemq, camel-spring ve camel-jms.

Aşağıdaki kod parçacığı, Camel'in activeMQ için nasıl yapılandırılacağını gösterir.

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

Burada Camel uygulaması, adı verilen bir kuyruğu dinlemeye başlayacaktır. orderQueue. Sıranın kendisi, yerel ana bilgisayarda çalışan ve 61000 numaralı bağlantı noktasını listeleyen activeMQ mesajlaşma sunucusunda ayarlanır. Bu yapıldığında, uygulamanız, uygulamanızda tanımlanan uç noktalardan herhangi birinden bu kuyruğa mesaj gönderebilir veya alabilir.

Son olarak, Camel uygulamalarının nasıl oluşturulduğunu daha iyi anlamak için bir projede her şeyi bir araya getirmenin zamanı geldi.