Camel -传递给方法的属性参数在choice/when中不起作用
Camel是一个开源的集成框架，用于在不同的应用程序之间进行消息传递和数据交换。它提供了丰富的组件和工具，可以简化系统集成的开发过程。
在Camel中，属性参数可以通过Exchange对象传递给方法。Exchange对象是Camel中消息的容器，它包含了消息的头部、主体和属性等信息。属性参数可以在路由的不同步骤中进行传递和处理。
在choice/when语句中，可以使用属性参数来进行条件判断。choice语句用于根据一系列条件选择不同的路由路径，when语句用于定义条件判断的表达式。然而，有时候传递给方法的属性参数在choice/when中可能不起作用，这可能是由于以下原因导致的：
- 属性参数的名称或值不正确：请确保属性参数的名称和值与choice/when语句中的条件判断一致。
- 属性参数的作用域不正确：属性参数的作用域取决于它们被设置的位置。如果属性参数在choice/when语句之前被设置，那么它们可能无法在条件判断中起作用。请确保属性参数在需要使用它们的位置之前进行设置。
- 路由逻辑错误：可能存在其他路由逻辑或条件判断语句，导致属性参数在choice/when中不起作用。请检查整个路由逻辑，确保没有其他条件判断语句干扰了属性参数的传递和使用。
总结起来，当传递给方法的属性参数在choice/when中不起作用时，需要仔细检查属性参数的名称、值、作用域以及整个路由逻辑，以确保属性参数能够正确传递和使用。
腾讯云提供了一系列与Camel相关的产品和服务，例如云消息队列CMQ、云服务器CVM、云函数SCF等，可以与Camel集成使用。具体产品介绍和链接地址可以参考腾讯云的官方文档和网站。
相关·内容
我正在尝试在camel路由中使用属性占位符。我有定义属性: MQ.queuename1=TESTQUEUE的test.properties。在camel上下文中，我定义了占位符：
<camel:camelContext xmlns="http://camel.apache.org/schema/spring" >
<propertyPlaceholder id="camel-properties" location="file:${web.external.propdir}/test.properties"/>
在该
浏览 1提问于2014-02-25得票数 4
回答已采纳
在我使用Talend6.5构建的路由中，使用的是Saxon9.5JAR，因此所有的XPath谓词都是使用Saxon进行计算的。 为了使用更新的Camel版本，我升级到了Talend7.1，现在使用的是Saxon9.8版本，我从(Apache Camel Xpath 2.0 with Saxon does not look to work in RouteBuilder / Predicates)了解到9.6+不会自动使用。 理想情况下，我希望将Saxon用于Camel中的所有xslt/xpath计算，而我可以对XSLT组件使用saxon=true修饰符，但我不知道如何将其与选择谓词一起使用。
浏览 22提问于2019-02-07得票数 0
4回答
Apache Camel条件路由
、、、、
我有一个包含两个操作的服务。
RegisterUser
UpdateUser
我有一个骆驼溃败：
<camel:route id="myRoute">
<camel:from uri="cxf:bean:myListenerEndpoint?dataFormat=POJO&synchronous=true" />
<camel:bean ref="processor" method="processMessage"/>
<ca
浏览 5提问于2012-07-27得票数 10
回答已采纳
2回答
我遵循了一本书“骆驼行动”中的一个例子。如何编组和解组csv数据格式。但是，我想使用(逗号分隔分隔符)和拆分正文来解组csv文件。然后，我将使用基于内容的.choice根据所需的任务分发消息。事实上，第一个简单的例子对我不起作用。我使用了camel 2.15.6 (camel-core，camel-context，camel-csv，commons-csv)和java 7。
public void configure()
{
CsvDataFormat csv = new CsvDataFormat();
csv
浏览 7提问于2017-06-08得票数 0
我有一个Camel路由(除其他外)应该运行验证器，但前提是设置了某个属性，即com.acme.ValidatorOn。
这条路线的相关部分如下：
<choice>
<when>
<simple>{{com.acme.ValidatorOn}} == true</simple>
<to uri="validator:MyWebService.xsd" />
</when>
</choice>
当我注意到即使属性设置为false时验证器也总是被执行时，
浏览 2提问于2015-09-08得票数 3
我们根据存储在数据库中的配置参数动态构建camel路由。我们有构建所有骆驼路由的泛型类。其中一些参数只是以原始的Camel Spring XML表示的。构建驼峰路由的类扩展了RouteBuilder，下面是构建驼峰路由的代码的一部分：
@Override
public void configure() throws Exception {
RouteDefinition route = from(inputFile);
configureSpringXMLActivity(0, route, convertBodyXml);
config
浏览 1提问于2016-12-02得票数 0
我正在尝试让Camel路由执行基于条件语句的操作；如果该条件为真，则它将执行该操作。但是，如果该条件为假，则不会执行该操作。
条件语句基于从".properties“文件中提取的属性的值。我已经为bean中的属性定义了placeholderPrefix和placeholderSuffix，它们分别是{{和}}。如果有帮助，该定义看起来如下所示：
<bean id="com.example.springPropertyConfigurer"
class="com.example.PropertiesSpringPlaceholderConfigure
浏览 3提问于2015-09-15得票数 4
1回答
我有一个使用Camel的项目，并且我的路由有一个对自身的递归调用，以便实现逻辑“在返回数据集时调用存储过程”：
<route id="trxnReader">
<from uri="direct:query"/>
<to uri="sql-stored:classpath:sql/getTrxnsProcedure.sql?dataSource=myDataSource"
id="storedprocGetTrxns"/>
<choice>
浏览 6提问于2020-02-04得票数 2
2回答
我想在某种情况下退出Camel Loop。我使用的是Camel 2.15
.loop(simple("${exchangeProperty.loopCount}"))
.to("bean:xxx?method=exitFromLoop")
.end()
我尝试在exitFromLoop方法中更改CamelLoopIndex和CamelLoopSize，但对我不起作用。
除了这个之外，还有其他选择吗?例如，使用choice/何时？
浏览 50提问于2016-08-09得票数 3
回答已采纳
1回答
我有骆驼路线，根据头值进行rest调用。我一直在使用xpath从xml读取值并将它们设置为标头，并在块中使用xpath，如下所示：
<camel:setHeader headerName="clear">
<xpath>/TicketInfo/TicketData/Clear/text()</xpath>
</camel:setHeader>
<camel:choice>
<camel:when>
<camel:xpath>$clear=&#
浏览 1提问于2016-02-15得票数 1
回答已采纳
如何比较正文内容匹配(equals或startWith)值
{"status":"OK"}
怎么做到的？
<camel:choice>
<camel:when>
<simple>${in.body} == '{"status":"OK"}'</simple>
...
</camel:when>
</camel:choice>
我试着：
'{"status":"OK"}'
'{\
浏览 2提问于2018-04-18得票数 0
回答已采纳
1回答
我有一个包含多个消费者的JMS队列。我试着沿着骆驼的路线走，
<camel:camelContext id="camel-server">
<camel:package>com.camlin.consumer</camel:package>
<camel:route id="one">
<camel:from uri="jms:queue:request" />
<camel:choice>
浏览 0提问于2014-01-22得票数 1
回答已采纳
在我的Apache Camel应用程序中，我有多个条件来检查JSON中是否存在键。我想减少样板代码，因此我需要将我的Expression转换为Predicate。 我用Expressions编写的代码： .choice()
.when().jsonpath("$.score", true).to("direct:b")
.when().jsonpath("$.points", true).to("direct:b")
.otherwise().to("direct:c"); 另请参阅：JS
浏览 30提问于2021-08-20得票数 0
我正在使用Spring向Camel获取JSON格式的数据。我是这样写代码的，
<bean id="mqtt" class="org.apache.camel.component.mqtt.MQTTComponent"/>
<bean id="gson" class="org.apache.camel.component.gson.GsonDataFormat"/>
<camel:camelContext xmlns="http://camel.apache.org/schema
浏览 2提问于2013-10-24得票数 0
回答已采纳
我们使用拆分器来迭代压缩文件中的文件，同时，我们还使用了一个自定义聚合器，它为我们提供了一个正文列表--主压缩文件中的两个文件的列表。现在，在拆分之后，我想提取在聚集器结果上发生的聚集块处理期间设置的头。但是，聚合器的输出似乎丢失了，并且在拆分块之后我没有得到任何东西。
我确信我没有得到这方面的基本知识。如果有人能帮上忙我会很感激的。
<route id="main-route">
<split streaming="true">
<ref>zipSplitter</ref>
浏览 3提问于2015-08-28得票数 2
我是camel的新手，我想知道，考虑到下面的路由，我如何存储进入路由的原始消息，以便记录它。因此，在下面的when条件中，我调用了一个bean方法，如果该方法返回true，我希望将原始消息写入文件。下面的示例想要编写来自bean调用的响应，而不是进入路由的原始消息。
我正在考虑使用下面这样的setProperty，但后来我不确定如何使用文件组件将其写出来？
<setProperty propertyName="origInData">
<simple>${body}</simple>
</setProperty>
浏览 2提问于2014-05-21得票数 0
我的要求是每隔几分钟轮询一个数据库并获得一个sql。因此我的代码是
<camel:route>
<camel:from uri="timer:dataRetrieve?period=5s"/>
<camel:to uri="sql:select output_obj,create_dt,destination_type from dbo.gcas_events_test where process_sw = 'N' order by create_dt desc" />
浏览 0提问于2014-05-20得票数 0
回答已采纳
我正在自学python，我正在尝试创建一个密码生成器。我想要程序做的是，生成一个随机密码并将其保存到文本文件中。我在获取密码以保存到文本文件方面有什么问题。我能够获得一个生成的密码，但是我在text_file file.write( output ) NameError中得到了一个错误代码:虽然我已经定义了输出，但没有定义名称'output‘。如果有人能告诉我我做错了什么，我会很感激的。如果需要更多的信息，请告诉我。谢谢
import random
import string
# Generates a password from random.choice
length = int
浏览 2提问于2020-06-04得票数 0
回答已采纳
我有很多选择，但这条路只适用于最后一种情况。在其他情况下，路线会被卡住，不会继续前进。
public class CamelChoiceTest {
private CamelContext context;
@Before
public void initializeContext() throws Exception {
RouteBuilder builder = new RouteBuilder() {
public void configure() {
from("direct:test")
浏览 6提问于2015-03-14得票数 3
回答已采纳
我正在尝试将条件与PredicateBuilder复合，并将其保存到头中，以便从when()函数访问谓词。一开始，我将身体设置为Hello World。此外，主体不是null或不等于AUTHENTICATE failed，但是我进入了when块，process_no_mail_or_failed正在被记录。我不明白我做错了什么。如何在Apache中复合谓词并在when()函数中使用它们？以防我需要在某一步检查身体。所以我就这样做了。
我接受任何帮助！
Apache路由：
import org.apache.camel.Exchange;
import org.apache.camel.Mess
浏览 1提问于2022-05-13得票数 0
回答已采纳
我正在使用Apache Camel 2.17，并使用简单的语言来捕获空交换。它不起作用，我已经尝试了几种格式化方法，但都没有捕捉到null。我相信这是我如何使用它的格式/语法。请告诉我哪里出错了。谢谢!
<process id="_process18" ref="csvMarshallerProcessor"/>
<process id="toReOrgCSV" ref="reOrgCSVData"/>
<choice id="_choice13">
<when i
浏览 14提问于2019-10-21得票数 0
回答已采纳
我必须在camel中写入多个if条件，我需要帮助才能四处走动。
if(token is NULL)
if(condition is NULL)
if(Dates does not match)
Then execute this...
我想要做的是
.choice
.when(token is NULL)
.when(condition is NULL)
.when(Dates does not match)
.log(update DB)
.endchoice()
这不管用..请帮帮忙
浏览 0提问于2016-12-16得票数 1
回答已采纳
我希望有一个允许使用可选自定义处理器的基类RouteBuilder。如果一个子类指定了它，那么将它添加到路由中，否则不会。
我一直在尝试使用choice() when() otherwise()结构，但不用说没有成功。我是新使用Apache的，所以我不知道如何解释/修复错误消息。如果定义了自定义处理器，它可以正常工作，但如果为null，我将得到下面的错误消息。
package test;
import org.apache.camel.CamelContext;
import org.apache.camel.LoggingLevel;
import org.apache.camel.Pre
浏览 2提问于2019-10-08得票数 0
追踪：
org.apache.camel.FailedToStartRouteException: Failed to start route FromSAA because of null
at org.apache.camel.impl.engine.RouteService.setUp(RouteService.java:132)
at org.apache.camel.impl.engine.InternalRouteStartupManager.doInitRoutes(InternalRouteStartupManager.java:92)
at org.a
浏览 16提问于2022-08-18得票数 0
1回答
我是Apache的新手，我使用Red Studio 12.16.0.GA，我希望调用soap服务。我用了这个例子
这是我的骆驼上下文文件
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:camel-cxf="http://camel.apache.org/schema/cxf"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="
浏览 1提问于2020-09-03得票数 0
回答已采纳
我是阿帕奇骆驼的新手。我已经将我的应用程序设置为使用基于XML的配置的Apache。我的配置包含具有类似步骤集的多个路由。我试图找出一种方法，将这些不同路线的公共部分或重复部分放置在一个地方，并从路线中引用它们，而不是一次又一次地重复它们？
例如，在我下面的骆驼路线配置中，路线2是重复路线1的几个步骤，那么有没有办法提取路线1和路线2的共同步骤，然后引用从路线1和路线2提取的部分？
<context:property-placeholder location="classpath:quartz.properties" />
<context:componen
浏览 0提问于2014-01-06得票数 0
回答已采纳
我正在使用camel -spring.I编写一个基本的camel应用程序。我可以发送电子邮件，但我不能在其中发送正文和主题。我尝试了几种方法，但我在邮件正文中唯一得到的是文件contents.Please，如果您有任何想法，请提供您的输入。
<route id="notification">
<from uri="file:///home?noop=true" />
<camel:choice>
<camel:when>
浏览 2提问于2018-02-16得票数 1
回滚事务不起作用。
我试图在bean ActiveMQComponent中设置参数
cacheLevelName => CACHE_CONSUMER
transacted => true
如何修正这个错误？
日志：
[ad #8 - JmsConsumer[Caosqueue]] TransactionErrorHandler WARN Transaction rollback (0x67756120) redelivered(false) for (MessageId: ID:stws2327-61437-1452674698638-1:3:1:1
浏览 8提问于2016-01-13得票数 0
回答已采纳
我正在配置一个类似于以下内容的apache-camel路由：
<camelContext xmlns="http://camel.apache.org/schema/spring">
<propertyPlaceholder id="properties" location="file:/../jboss/dependencies-fuse/archivo.properties"/>
<route>
<from uri="amqLocal:e
浏览 2提问于2016-04-07得票数 2
回答已采纳
3回答
我的路由中有一个端点不能在本地安装--因为缺少一些属性，这些属性不可用，无法在本地环境中访问。
因此，当我在本地环境中启动应用程序时，我会得到错误的org.apache.camel.FailedToCreateRouteException。但是，在服务器环境中，它工作得很好。
如何防止camel在本地环境上初始化端点(我有一个属性可以确定环境是否是本地的)？就像这样
<choice>
<when>
<simple>{{is.local}} == true</simple>
<to uri="d
浏览 0提问于2017-05-05得票数 0
回答已采纳
我正在尝试在Exchange.property上设置一个属性Exchange.property，然后当在路由中对其进行评估时，使用Select。
属性正在被设置，但我总是得到，否则结果(NACK)，不管isEven设置为什么。
这里是我设置它的地方：
// Below is used for development
// If the property.isEven == true then an ACK will be returned from the Mock HRM
// If false then NACK
int lastDigit = Integer.parseInt(
浏览 16提问于2014-02-20得票数 2
我试图找到一种方法来配置Camel端点，该方法使用在camel上下文中的路由中的端点声明中引用的spring bean，但它不起作用。
例如，有时使用许多参数定义端点URI是非常可怕的(!!)，使用bean及其属性配置端点会容易得多。(或者更好的做法是，在XML中配置端点时，也许或元素应该具有像常规bean这样的子元素，我们可以在其中配置端点的参数)。
下面的第一种方法工作得很好，而且非常标准和简单。第二种方法是我想使用的方法，但它不起作用。我尝试了许多变体，但都没有成功！下面的第三个替代方案实际上对Camel开发人员来说是一个有趣的建议，但它也说明了我的观点。
在下面的示例中，我只为file
浏览 2提问于2014-10-03得票数 1
我正在尝试用私钥对JMS文本消息的有效负载进行签名。然后将消息发送到队列并相应地路由。签名将与公钥一起放在消息头中。
我使用下面的代码来使用公钥设置报头。
TextMessage textMessage = session.createTextMessage(message);
String publicKey = new String(pubk.getEncoded());
textMessage.setStringProperty("CamelSignaturePublicKeyOrCert", publicKey);
然而，当消息开始路由时，我会得到以下错误
11:13
浏览 6提问于2013-12-04得票数 0
回答已采纳
2回答
我试图根据属性文件中的布尔值有条件地启动XML中的路由。但这有点不管用。我不确定这样做是否正确。如有任何帮助，谢谢:)
这是我的blueprint.xml
<bean id="bridgePropertyPlaceholder" class="org.apache.camel.spring.spi.BridgePropertyPlaceholderConfigurer">
<property name="location" value="classpath:property.properties"/>
浏览 3提问于2017-09-08得票数 0
回答已采纳
我试图在Spring中使用Groovy脚本，如下所示：
<from uri="file://{{my.path}}">
<choice>
<when>
<groovy>properties.resolve 'file.one.isActive' == 'true'</groovy>
<to uri="file://{{file.one}}"/>
</when>
浏览 0提问于2014-08-24得票数 2
回答已采纳
首先，是的，我已经搜索过了，并且，是的，我已经阅读了每个人都指向的相同的Apache文档。:-)我认为有一点混乱，我想我知道答案，所以让我举一个我认为正确的例子，跟随我认为答案是什么。谢谢。哦，我确实知道有些endChoice()行并不是绝对必要的，Camel会解决这个问题的，但我喜欢清晰地描述这些块，除非有什么理由不使用它们。
.choice()
.when(X1)
// do stuff
.choice()
.when(Y)
//do more stuff
.endCho
浏览 0提问于2015-09-04得票数 19
回答已采纳
当我部署到jboss时，Camel验证不起作用，与mvn jetty:run配合很好。请参阅下面的错误：
Stacktrace
---------------------------------------------------------------------------------------------------------------------------------------
java.lang.IllegalArgumentException: Source parameter of type 'org.apache.camel.StringSource'
浏览 0提问于2013-12-03得票数 0
我正在将osgi应用程序部署到JBoss Fuse / Apache，而javascript语言不想解决这个问题。
此错误出现在日志中：
ERROR | BluePrinntContainerImpl | Bundle my-service is waiting for dependencies
[(&(language=js)(objectClass=org.apache.camel.spi.LanguageResolver))]
最近，我向一个.javaScript()语句添加了一个.choice()表达式定义：
.choice()
.when()
.javaScr
浏览 0提问于2014-01-08得票数 0
回答已采纳
3回答
我正在用mule studio开发一个应用程序，我需要使用“选择”组件，但我想评估的不是有效负载中包含的消息属性，而是包含在属性文件中的变量，如下所示：
<choice doc:name="Choice">
<when expression="${CONTROL_VARIABLE}.equals("S")">
<set-variable variableName="URL_ADDRESS" value="
浏览 0提问于2013-08-30得票数 3
回答已采纳
我使用的是activeMQ 5.9。
我正试图在我的activemq.xml中实现一个拦截类型的路由，我检查一个特定的报头是否等于某个值，然后将其发送到不同的队列，否则允许它继续。
我正在关注这里的信息：
我的camel.xml文件如下所示：
<camelContext id="camel" trace="false" xmlns="http://camel.apache.org/schema/spring">
<route id="routeAboveQueueLimitTest">
浏览 0提问于2014-05-28得票数 0
我正在实现骆驼路由，在此过程中，我需要在将消息处理重定向到端点(取决于routing slip头)之前放置一个过滤器。如下所示：
from("direct:a")
.routeId("a")
.choice()
.when(header("foo"))
.filter(body().isNotNull())
.routingSlip(header("my-slip&
浏览 4提问于2021-07-28得票数 0
回答已采纳
我刚刚开始使用Apache Camel，我想尝试同步两个表。这两个表都有两列，"id“和"name”。该场景将查询第一个表，检查第二个表中是否存在每条记录，然后插入不存在的每条记录。这是我的尝试：
<camel:camelContext id="test">
<camel:route>
<camel:from uri="timer://kickoff?period=5s"/>
<camel:to uri="sql:select id, name from t
浏览 2提问于2012-12-29得票数 0
回答已采纳
我有一个routeContext，在其中我试图确定以下内容。如果JMSXDeliveryCount (一个消息属性)小于5，我希望回滚。如果大于5，我想记录一条消息并离开。
下面是我的routeContext：
<routeContext id="inbound-errorhandler-route" xmlns="http://camel.apache.org/schema/spring">
<route id="errorhandler">
<from uri="direct:inb
浏览 2提问于2018-04-06得票数 2
4回答
在我的应用程序上下文中，我有一条骆驼路线被定义为
<camelContext xmlns="http://camel.apache.org/schema/spring"
trace="true" id="camel">
<route id="wsProxyRedirection">
<from uri="cxf:bean:cdcPocProxyWebServiceStartPoint" />
<choice>
浏览 6提问于2017-09-06得票数 2
回答已采纳
3回答
我想配置一个驼峰路由，在这里可以在运行时指定to(uri)。
我尝试了以下几种方法：
public class Foo extends RouteBuilder {
@Override
public void configure() {
// the URI can point to different hosts
from("direct:start").to(${someUri}");
}
}
然后
ProducerTemplate pt = camelContext.createProducerTemplat
浏览 1提问于2012-07-05得票数 2
回答已采纳
from("somegcpchannel").
.choice()
.when().jsonpath(myClassObject.getJsonPathExpressions().get(),true)//true will suppress exception if the path does not exist"
这个camel jsonpath组件的问题是，如果myClassObject.getJsonPathExpression()为null或空，它会抛出一个exception.Hence，我被迫放置一
浏览 20提问于2020-06-05得票数 0
我有以下流程：
<flow name="SOAPWebService" doc:name="SOAPWebService">
<http:inbound-endpoint address="http://localhost:8088/esb/" exchange-pattern="request-response" doc:name="HTTP">
</http:inbound-endpoint>
<choice doc:name=&#
浏览 0提问于2013-05-17得票数 0
回答已采纳
在我的应用程序中，我必须通过调用then服务来验证传入消息的授权。例如，如果用户属于授权组，则只处理消息。为此，我必须从传入消息的一个属性(例如userId(而不是整个传入消息))构建authorizationRequest并发送到webservice。
我是第一次接触camel。要在非camel应用程序中实现这一点，我需要创建一个webservice客户端，使用userId(参数)进行调用并处理响应。主要的驼峰路线：
from( <URI> ).routeId("UpdateRoute")
.process("Authori
浏览 0提问于2017-02-11得票数 2
由impl类实现的接口如下所示
@POST
@Path("/callA/{A}")
public FObj invokeA(@PathParam("A") int a,FObj fobj);
我的customRouteBuilder正在将请求路由到上面公开的服务。
.choice().when().simple("${header.operationName} == 'CallA'")
.to("bean:BeanA?method=invokeA")
但是当我从Rest客户端通过设置有效载荷中的对象
浏览 0提问于2018-05-24得票数 0
在Apache Camel中，有没有办法在file://端点的fileName参数中使用条件表达式？
我正在使用Java DSL (无法更改这一点)来构建路由，但下面的定义似乎不起作用
myroute.to("file://my-file-out?fileName=${header[myheader] eq 'EXPECTED_VALUE' ? 'EXPECTED' : 'UNEXPECTED'}")
不幸的是，我必须在一个.to()方法调用中完成这个任务，因为我使用的是一个预定义的(自定义)应用程序框架。
浏览 0提问于2018-06-22得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
