连接到Camel-SEDA队列

Question

我无法连接到具有SEDA队列的骆驼路线。在服务器端，我有以下配置：

<camel:route>
            <camel:from uri="seda:input"/>
            <camel:log  message =">>>>>data is : ${body}"/>
            <camel:inOnly uri="activemq:queue:TESTQUEUE"/>
        </camel:route>

我正在尝试从这样的独立客户端访问此路由：

public static void main(String[] args) {

        CamelContext context = new DefaultCamelContext();
        producer = context.createProducerTemplate();
            producer.sendBody("seda:input","Hey");

}

但我的制作人无法连接到seda队列。无法按我的路线排队。无法在我的bean属性中添加camelContext。我正在获取“bean类的属性'camelContext'无效”。如果我将正文发送到SEDA队列，则消息将发送到那里，但不会发送到路由的下一个元素

Answer 1

骆驼中的SEDA成分作为异步内部通道。如果您需要将消息处理解耦到多个线程中并具有更具弹性的实现，这将非常有用。

在您的示例中，您有一个 activemq endpoint。在概念基础上，它将执行与SEDA组件几乎相同的功能，但具有更多的功能。我建议你使用activemq或其他协议来与Camel通信的客户端。

也就是说，如果您的客户端运行在与Camel相同的java应用程序中，并且您的客户端可以获得Camel上下文（这是我通常建议反对的设计），您可以使用产品模板向SEDA组件发送消息。看看虚拟机组件，它与SEDA几乎相同，但可以在同一个虚拟机中使用，而不是在同一个骆驼上下文中。生产者模板是如何工作的。

Answer 2

正如Petter所建议的，您的客户端需要连接到定义SEDA路由的相同Camel Context。在您的示例中，您似乎正在创建一个新的DefaultCamelContext（）并尝试将消息发送到在另一个上下文中定义的路由。

通常，我在Spring XML中定义Camel Context，然后将上下文注入任何需要它的类……

<camelContext id="camelContext" xmlns="http://camel.apache.org/schema/spring">
    <routeBuilder ref="myRouter"/>
</camelContext>

<bean id="myClient" class="com.mycompany.MyClient">
    <property name="camelContext" ref="camelContext"/>
</bean>

然后，您的客户端代码只需调用以下命令。。。

getCamelContext().createProducerTemplate().sendBody("seda:input","Hey");

也就是说，如果您的客户机代码不在同一个JVM中，或者无法获得同一个CamelContext的句柄，那么您可以选择使用JMS、REST、HTTP(或任何支持远程客户机接口的camel组件)...而不是SEDAendpoint或其附近。

例如，您可以像这样用HTTPendpoint(通过camel-jetty)包装对SEDA队列的访问...

from("jetty:http://localhost:9001/input").to("seda:input");