骆驼不通过交易所属性

Question

我需要在Exchange对象的属性上传递一些参数。据我所知和阅读，最好在交换属性上创建我的参数，因为消息的标头可以在路由期间更改。Camel正在从一个路由到另一个路由创建新的交换，但不保留我的任何参数的历史记录。

现在一些上下文：我正在使用部署在WebLogic 12C上的Camel（2.16.1）

相关的Maven部分：

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <camel.version>2.16.1</camel.version>
  </properties>

  <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-web</artifactId>
            <version>4.1.6.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-core</artifactId>
            <version>${camel.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-spring</artifactId>
            <version>${camel.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-cxf</artifactId>
            <version>${camel.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-jms</artifactId>
            <version>${camel.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-test-spring</artifactId>
            <version>${camel.version}</version>
        </dependency>
        <dependency>
            <groupId>javax.ejb</groupId>
            <artifactId>ejb-api</artifactId>
            <version>3.0</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
            <version>1.7.13</version>
        </dependency>
    </dependencies>

骆驼上下文：

<camelContext xmlns="http://camel.apache.org/schema/spring">
    <route>
        <from uri="file:/Users/user/camel-test/in?noop=false" />
        <process ref="TestProcess"/>
        <to uri="file:/Users/user/camel-test/out" />
    </route>
    <route>
        <from uri="file:/Users/user/camel-test/out?noop=false" />
        <process ref="TestProcess"/>
        <to uri="jms:CamelServer/CamelJMSModule!CamelQueue" />
    </route>
</camelContext>

如您所见，我使用了一个名为TestProcess的类来影响Exchange对象，如下所示：

package com.test.camel;

import org.apache.camel.Exchange;
import org.apache.camel.Processor;

public class TestProcess implements Processor {

    public void process(Exchange exchange) throws Exception {

        //Just to get the Exchange ID, this ID is changing between routes
        System.out.println(exchange.getExchangeId());

        //The first time i try to get my custom property should return null of course
        System.out.println(exchange.getProperty("MY_PARAMETER_ID"));

        //So if my property does not exist in properties i will create it
        if(exchange.getProperty("MY_PARAMETER_ID") == null) {
            exchange.setProperty("MY_PARAMETER_ID", "SOME_VALUE");  
        }
    }
}

我的问题是：在所有路由过程中，我从未在属性上获取属性。我的目标是在Camel开始路由我的消息时设置一些属性，并使这些属性一直可用到进程结束。

TestProcess类演示了我如何尝试访问属性。我还尝试了XML，但效果不佳：

<camelContext xmlns="http://camel.apache.org/schema/spring">
    <route>
        <from uri="file:/Users/user/camel-test/in?noop=false" />
        <setProperty propertyName="MY_PARAMETER_ID">
                <simple>some-value</simple>
        </setProperty>
        <to uri="file:/Users/user/camel-test/out" />
    </route>
    <route>
        <from uri="file:/Users/user/camel-test/out?noop=false" />
        <log message="MY_PARAMETER_ID = ${header.MY_PARAMETER_ID}" />
        <to uri="jms:CamelServer/CamelJMSModule!CamelQueue" />
    </route>
</camelContext>

更新：在一些人说无法从文件endpoint（仅jms或direct）发送属性/头属性后，我尝试使用jms，但仍然存在相同的问题，正如您在上下文中看到的：

<camelContext xmlns="http://camel.apache.org/schema/spring">
    <route>
        <from uri="jms:CamelServer/CamelJMSModule!ReceiverQueue" />
        <setProperty propertyName="MY_PARAMETER_ID">
            <simple>some-value</simple>
        </setProperty>
        <to uri="jms:CamelServer/CamelJMSModule!CamelQueue" />
    </route>
    <route>
        <from uri="jms:CamelServer/CamelJMSModule!CamelQueue" />
        <log message="MY_PARAMETER_ID = ${header.MY_PARAMETER_ID}" />
        <to uri="jms:CamelServer/CamelJMSModule!FinalQueue" />
    </route>
</camelContext>

有什么想法吗？我做错了什么？

在我只使用JMS的示例中，唯一没有从Exchange对象更改为其他对象的属性是：

exchange.getIn().getHeader("breadcrumbId")

根据Camel文件，这是：

Camel 2.8：用于跨传输跟踪消息的唯一id。

但这种面包屑索引只在JMS路由中保持不变，而不在文件路由中保持不变。

谢谢

Answer 1

由于您正在使用新版本的骆驼，这似乎已经发生了。http://camel.apache.org/property.html

从Camel 2.15开始，属性语言已重命名为exchangeProperty，以避免作为通用术语与属性产生歧义、混淆和冲突。因此，在使用Camel 2.15以后的版本时，请使用exchangeProperty而不是property。

<route>
  <from uri="direct:a" />
  <recipientList>
    <exchangeProperty>myProperty</exchangeProperty>
  </recipientList>
</route>

尝试在xml dsl中使用字段访问exchange属性。

Answer 2

土壤工人解释了为什么在路由之间使用文件时它不起作用。当您切换到JMS时，默认情况下它仍然只发送消息正文。要发送整个交换，您需要在JMSendpoint上启用transferExchange属性。它在他的回答中包含的留档链接中。

在这一点上，我个人建议不要通过外部连接传输交换，而是使用一种允许您在消息正文中传递任何所需属性的格式。从长远来看，这将为您提供更大的灵活性，而不是将您束缚在特定的传递机制上。

编辑：哦，应该已经检查了原始问题的日期。但由于最初没有提到这一部分，我认为有必要澄清为什么仅仅切换到JMS是不够的。

Answer 3

无法通过文件endpoint在两条路由之间路由标头/属性值。例如，使用直接endpoint或jms在两条路由之间进行通信。

看见http://camel.apache.org/direct.html或http://camel.apache.org/jms.html了解更多信息。