5

我正在开发一个解决方案，其架构是：

  PHP -> JMS -> Camel -> several web services and endpoints.

根据：http ://activemq.apache.org/php.html

...我应该使用 PHP STOMP 客户端来使用 JMS。这很好用。

我还使用 ActiveMQ STOMP Java 客户端从 JMS 接收。

但是，我想使用 Camel 来路由 JMS 消息。我似乎无法让 Camel 与 JMS / Stomp 一起工作。

我看了一下https://github.com/fusesource/stompjms

...但我不知道如何让它与骆驼一起工作。

我还尝试了一个带有指定 STOMP 的 brokerURL 的 Spring camel-context.xml：

  <bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
      <property name="connectionFactory">
          <bean class="org.apache.activemq.ActiveMQConnectionFactory">
              <property name="brokerURL" value="stomp://localhost:61613" />
              <property name="userName" value="admin" />
              <property name="password" value="AmChamDev" />
          </bean>
      </property>
  </bean>

...但是，这导致：

  [ #0 - JmsConsumer[/queue/test]] ultJmsMessageListenerContainer WARN  Could not 
  refresh JMS Connection for destination '/queue/test' - retrying in 5000 ms. 
  Cause: Could not create Transport. 
  Reason: java.io.IOException: Transport scheme NOT recognized: [stomp]

关于如何让 Camel 与 JMS / Stomp 一起工作的任何想法？

4

2 回答 2

6

使用 JMS/ActiveMQ 组件时，您必须使用开放式线路传输。

tcp://localhost:61616或者你有什么。

但别担心。即使您使用 STOP（或任何其他可用传输）向 ActiveMQ 发送消息，您也可以使用默认（开放线）传输使用 JMS api（以及 Camel 中的 ActiveMQ 组件）接收相同的消息。

于 2013-02-23T20:08:39.510 回答
2

根据骆驼文档http://camel.apache.org/stomp.html你需要包括额外的依赖：

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-stomp</artifactId>
    <version>x.x.x</version>
    <!-- use the same version as your Camel core version -->
</dependency>
于 2015-05-20T12:12:54.890 回答