Apache Camel-메시지 큐

대부분의 통합 프로젝트는 느슨하게 결합 된 애플리케이션 아키텍처를 만드는 데 도움이되는 메시징을 사용합니다. 메시징은 동기 또는 비동기 일 수 있습니다. JMS는point-to-point 과 publish-subscribe모델. 당신은Queue 지점 간 및 Topic발행-구독 모델의 경우. Java 플랫폼에서 JMS-Java Messaging Service는 메시징 서버에 대한 인터페이스를 제공합니다. Apache activeMQ는 그러한 오픈 소스 JMS 공급자 중 하나입니다. Camel은 JMS 공급자와 함께 제공되지 않습니다. 그러나 activeMQ를 사용하도록 구성 할 수 있습니다. 이 구성 요소를 사용하려면 프로젝트에 다음 jar (activemq, camel-spring 및 camel-jms)를 포함해야합니다.

다음 코드 스 니펫은 activeMQ에 대해 Camel을 구성하는 방법을 보여줍니다.

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

여기서 Camel 애플리케이션은 다음과 같은 큐를 듣기 시작합니다. orderQueue. 대기열 자체는 로컬 호스트에서 실행되고 포트 61000에 나열되는 activeMQ 메시징 서버에 설정됩니다.이 작업이 완료되면 응용 프로그램은 응용 프로그램에 정의 된 모든 끝점에서이 대기열로 메시지를 보내거나받을 수 있습니다.

마지막으로, Camel 애플리케이션이 어떻게 생성되는지 더 깊이 이해하기 위해 모든 것을 프로젝트에 통합 할 때입니다.