【问题标题】:Consuming messages from remote ActiveMq queue使用来自远程 ActiveMq 队列的消息
【发布时间】:2013-01-22 14:39:41
【问题描述】:

如何使用 Apache Camel 的 ActiveMQ 组件连接到 ActiveMQ 的远程实例?

【问题讨论】:

    标签: queue jms activemq message-queue apache-camel


    【解决方案1】:

    您可以为每个 ActiveMQ 实例定义一个端点:

    <bean id="instance1" 
       class="org.apache.activemq.camel.component.ActiveMQComponent">
       <property name="brokerURL" value="tcp://server1:61616"/>
    </bean>
    ...
    <bean id="instance2" 
       class="org.apache.activemq.camel.component.ActiveMQComponent">
       <property name="brokerURL" value="tcp://server2:61616"/>
    </bean>
    

    然后在路由中使用它 &lt;from uri="instanceX:myQueue"/&gt;&lt;to uri="instanceX:myQueue"/&gt;

    【讨论】:

    • 非常感谢 Alex.... 我已经添加了这个,我正在尝试添加组件,如下所示:'CamelContext aContext = new DefaultCamelContext(); ActiveMQComponent comp = ActiveMQComponent.activeMQComponent("vm://"远程系统的IP地址"?broker.persistent=false"); aContext.addComponent("jms",comp);'有了这个我无法连接到队列......
    • 远程连接需要指定 url,如 tcp://host:port 而不是 vm://。
    • 我确实尝试了您的上述建议,但无法连接到远程队列...我错过了什么,恐怕......你能帮忙吗? TIA
    • remore ActiveMQ实例是如何配置的?目标端口是否在activemq服务器上打开且未阻塞?你看到了什么错误?
    • 如何检查目标端口是打开还是关闭.. ???此外,根本没有显示任何错误.. [原谅我很愚蠢..我刚刚开始使用 ActiveMQ ]
    猜你喜欢
    • 2013-09-23
    • 1970-01-01
    • 2013-03-02
    • 1970-01-01
    • 2015-09-23
    • 2012-10-19
    • 2015-12-13
    • 2018-11-30
    • 2022-06-14
    相关资源
    最近更新 更多