Apache Camel - Antrian Pesan

Sebagian besar proyek integrasi menggunakan perpesanan karena membantu dalam membuat arsitektur aplikasi yang digabungkan secara longgar. Perpesanan dapat berupa sinkron atau asinkron. JMS mendukung keduanyapoint-to-point dan publish-subscribemodel. Anda menggunakanQueue untuk point-to-point dan Topicuntuk model publish-subscribe. Pada platform Java, JMS - Java Messaging Service menyediakan antarmuka ke server perpesanan. Apache activeMQ adalah salah satu penyedia JMS open source. Camel tidak melakukan pengiriman dengan penyedia JMS; namun, ini dapat dikonfigurasi untuk menggunakan activeMQ. Untuk menggunakan komponen ini, Anda perlu menyertakan toples berikut dalam proyek Anda - activemq, camel-spring, dan camel-jms.

Cuplikan kode berikut menunjukkan cara mengkonfigurasi Camel untuk 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>

Di sini, aplikasi Camel akan mulai mendengarkan antrian yang disebut orderQueue. Antrian itu sendiri diatur di server pesan activeMQ yang berjalan pada host lokal dan mendaftar ke port 61000. Setelah ini selesai, aplikasi Anda dapat mengirim atau menerima pesan ke antrian ini dari salah satu titik akhir yang ditentukan dalam aplikasi Anda.

Akhirnya, sekarang saatnya untuk menggabungkan semuanya dalam sebuah proyek untuk mendapatkan pemahaman yang lebih dalam tentang bagaimana aplikasi Camel dibuat.