Apache Camel Choice()：什么都不做
Apache Camel Choice()是Apache Camel框架中的一个路由处理器，用于根据一定的条件来选择不同的处理路径。它可以根据一系列的条件表达式来决定消息的路由方式，可以实现基于条件的消息过滤、路由和转换。
Choice()的主要作用是根据条件对消息进行分支处理，可以根据消息的内容、头部信息、属性等进行条件判断，并选择不同的处理路径。它可以根据条件表达式的结果，选择执行不同的处理逻辑，比如将消息路由到不同的终端、进行消息转换、过滤等操作。
Choice()的优势在于灵活性和可扩展性。它可以根据不同的条件进行动态路由，使得消息处理更加灵活和可配置。同时，Choice()还支持多个条件的组合和嵌套，可以实现复杂的条件判断和处理逻辑。
Apache Camel提供了丰富的条件判断语句，如equals、startsWith、contains等，可以根据具体的需求选择合适的条件判断方式。此外，Choice()还支持使用脚本语言编写条件表达式，如使用Groovy、JavaScript等。
在实际应用中，Choice()可以广泛应用于消息路由、消息过滤、消息转换等场景。比如，可以根据消息的类型将消息路由到不同的处理器进行处理；可以根据消息的内容进行过滤，只处理符合条件的消息；可以根据消息的属性进行转换，将消息转换为不同的格式。
对于腾讯云的相关产品，推荐使用腾讯云的Serverless Cloud Function（SCF）来实现Choice()的功能。SCF是一种无服务器计算服务，可以根据事件触发执行代码逻辑。通过编写相应的函数代码，可以实现Choice()的功能，并将消息路由到不同的处理逻辑。具体产品介绍和使用方法可以参考腾讯云的官方文档：腾讯云Serverless Cloud Function。
相关·内容
在下面的代码中，有人能解释一下doTry中的choice块是做什么的吗?为什么它不能捕获RuntimeCamelException？
<doTry>
<process ref="msgProcessor" />
<choice>
<when>
<simple>"false" == "true" && ${exchangeProperty.
浏览 2提问于2015-07-10得票数 1
我正在使用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
回答已采纳
这是在其中一个示例中提供的默认骆驼上下文。
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:camel="http://camel.apache.org/schema/spring"
xsi:
浏览 1提问于2015-04-01得票数 3
回答已采纳
我正在使用Camel进行单元测试，当我从Camel In Action存储库执行时，它工作得非常完美，但是当我将路由类型从SEDA更改为直接-vm时，它会失败，并收到以下消息：
由: org.apache.camel.component.directvm.DirectVmConsumerNotAvailableException:造成，端点上没有可用的消费者:direct://camel。交换[身份].
这两种类型，SEDA和direct的不同之处在于，第一种是异步的，第二种是同步的。这就是测试失败的原因吗？如何使直接vm类型的路由测试工作？
我用的是JDK 1.8和Camel 2.2
浏览 8提问于2021-07-15得票数 0
下面的场景使用apache camel 2.14.0、spring 1.5.9和AXCOM1.2.9
场景--当调用soap服务时，它应该可选地返回一个错误--此错误应该作为soap错误出现在响应中。
问题检测
我已经检测到了问题：-Spring的org.springframework.ws.soap.axiom.AxiomHandler(2.3.0)不创建SOAPFault对象- org.apache.axiom.soap.impl.llom.SOAPBodyImpl (1.2.15)不再检查元素的本地名称
问题--有一个更好的方法来处理apache的soap故障吗？
一种可能是使用th
浏览 8提问于2017-10-12得票数 0
当我部署到jboss时，Camel验证不起作用，与mvn jetty:run配合很好。请参阅下面的错误：
Stacktrace
---------------------------------------------------------------------------------------------------------------------------------------
java.lang.IllegalArgumentException: Source parameter of type 'org.apache.camel.StringSource'
浏览 0提问于2013-12-03得票数 0
我希望有一个允许使用可选自定义处理器的基类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
我正在将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
回答已采纳
通过在application.properties中将logging.level设置为包名，我无法让Camel DSL将调试日志打印到Spring Boot下的控制台： logging.level.org.test.logdemo=debug <-不打印调试日志 如果我将LoggingLevel设置为INFO或WARN，则会打印日志： .when(simple("${exchangeProperty.xmltestresult} == ''"))
.log(LoggingLevel.INFO, "2nd choice ID was empty
浏览 73提问于2021-08-15得票数 1
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
回答已采纳
1回答
我从队列中向rest发送请求，并获得响应back.if --响应不是201 --然后我必须再次将相同的请求推送到队列中。但是，当我把它推到队列中时，我会收到一个错误，如下所示：
temp-queue://ID:01HW828056-64546-1479908191870-15:3:1.：在以下内容中未收到OUT消息: 20000 millis到期回复消息和correlationID: Camel-ID-01HW828056-64538-1479908182896-32-4在目的地:correlationID上未收到
这是我的blueprint.xml
<?xml version=
浏览 1提问于2016-11-23得票数 0
我正在尝试在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
回答已采纳
我正在配置一个类似于以下内容的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
回答已采纳
我们根据存储在数据库中的配置参数动态构建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
我试图在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
回答已采纳
如何比较正文内容匹配(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
回答已采纳
我想要
_ from( A )
_ .split()...
_ .choice() //Choice 1
_ .when( predicate )
_ .process()
_ .choice() // Choice 2
_ .when( x )
_ .to( X )
_ .otherwise()
_ .to( Y )
_ .end() // to terminate inner choice
_ .endchoice() // tell camel we're back in the ou
浏览 1提问于2013-03-14得票数 12
回答已采纳
我使用的是Camel 2.17.0。我需要在blueprint.xml文件中使用简单语言中的in运算符，如下所示
<choice id="_choice3"> <when id="_when3"> <simple>${header.STATUS} in 'Draft,Review'</simple> ......
但是，它不能工作，并抛出以下
浏览 11提问于2020-01-25得票数 0
我在tomcat上部署了camel示例-servlet-tomcat-无弹簧示例。效果很好。我更改了camel-config.xml，但是我的错误很严重。
java.lang.IllegalArgumentException: Invalid uri: /camel-example/camel/hello. If you are forwarding/bridging http endpoints, then enable the bridgeEndpoint option on the endpoint: Endpoint[https://www.google.com]
at org
浏览 12提问于2013-12-02得票数 0
回答已采纳
我是阿帕奇骆驼的新手。我已经将我的应用程序设置为使用基于XML的配置的Apache。我的配置包含具有类似步骤集的多个路由。我试图找出一种方法，将这些不同路线的公共部分或重复部分放置在一个地方，并从路线中引用它们，而不是一次又一次地重复它们？
例如，在我下面的骆驼路线配置中，路线2是重复路线1的几个步骤，那么有没有办法提取路线1和路线2的共同步骤，然后引用从路线1和路线2提取的部分？
<context:property-placeholder location="classpath:quartz.properties" />
<context:componen
浏览 0提问于2014-01-06得票数 0
回答已采纳
1回答
我试图解压缩一个文件，并用一个特定的Xpath值单独处理xml文件。下面是Spring。
<camel:route id="unzip-file" startupOrder="400">
<from uri="file:{{download.folder}}?move={{download.archive}}&consumer.delay=10000"/>
<unmarshal ref="zipFileDataFormat"/>
<split str
浏览 0提问于2013-11-26得票数 0
回答已采纳
我试图在activemq中使用jsonpath聚合消息。但是当我尝试启动activemq时，我得到了这样的例外：
ERROR: org.apache.camel.RuntimeCamelException: org.apache.camel.FailedToCreateRo
uteException: Failed to create route route2 at: >>> Choice[[When[jsonpath{$.pers
on[?(@.position = 'manager')]} -> [To[activemq:queue:test.man
浏览 4提问于2015-03-24得票数 3
回答已采纳
我目前正在使用AciveMQ作为路由用途。但是现在我需要迁移到ibmMq。这是我对camelContext.xml的AciveMq配置。请帮我做ibmMq配置。提前谢谢。
<bean id="jmsConnectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"/>
&l
浏览 2提问于2016-01-07得票数 0
回答已采纳
我正在编写一个DSL路由读取不同CSV文件的路由。我正在过滤基于标题的CSV，并对它执行一些操作，比如解封送处理。我的路线：
CsvDataFormat csv = new CsvDataFormat();
//Route 1 for filter CSV based on header
from("file:/home/r2/Desktop/csvFile?noop=true")
.choice().when(body().contains("partyName"))
浏览 0提问于2018-01-29得票数 0
回答已采纳
我正在看一个关于Servlet的camel示例，它使用这个xml camel定义(camel-context.xml)：
<camelContext xmlns="http://camel.apache.org/schema/spring">
<route id="helloRoute">
<!-- incoming requests from the servlet is routed -->
<from uri="servlet:hello"/>
浏览 7提问于2017-01-11得票数 1
1回答
自动路由发现Camel
、、、
在我的应用程序中，我在一个文件夹中存储了一些xml文件，用于声明我的路由。我想在应用程序引导程序中上传我的所有路由，并将它们存储在我的camel上下文中。换句话说，我希望自动发现存储在这些xml文件中的路由。
以下是包含路径的文件的示例
<?xml version="1.0" encoding="UTF-8"?>
<routeContext id="myRoute" xmlns="http://camel.apache.org/schema/spring">
<route>
浏览 2提问于2015-07-09得票数 0
4回答
我有一个简单的REST服务。有客户端，可以通过ID获取客户端，如果没有请求ID的客户端，则返回404 not found。
下面是相关的部分：
rest("/client")
.consumes("application/json").produces("application/json")
.get("{id}")
.to("direct:getClient");
from("direct:getClient")
.bean(clientService,
浏览 1提问于2016-10-28得票数 3
1回答
我有一个应用程序使用apache，activemq等。我还使用camel缓存来缓存对象。我试图并行运行我的所有测试类，以减少构建时间。这是我使用的maven配置。
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-surefire-plugin</artifactId>
<version>2.18.1</version>
<configuration>
<
浏览 7提问于2015-04-09得票数 0
回答已采纳
1回答
我正在尝试找到一种通过Apache Camel附加客户端证书的优雅方法。它可以是Java或Spring XML。
我要发送到的所有服务器都有服务器证书，这将加密流量，但在发送消息之前，我需要将客户端公共证书附加到消息。服务器包含15个左右的证书及其对应的私钥。
我的主要配置是用Spring XML编写的，所以我不确定如何添加客户端证书。
(我是一个.NET用户，只有很少的java和0 Linux经验)
示例Spring：
<camel:route>
<camel:from uri="direct:GetEligibility"/&g
浏览 2提问于2013-05-30得票数 2
我刚刚开始使用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
回答已采纳
1回答
我使用Apache根据请求消息中的某个属性路由SOAP请求。消息与regex匹配，如果找到匹配，请求将被路由到"calldestination1“，如果不匹配，请求将被路由到"calldestination2”。
我使用以下配置：
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:camel="http://camel.apache
浏览 0提问于2019-01-25得票数 10
回答已采纳
对于下面的java DSL，什么是等价的xml，请建议
public class OrderRouter1 extends RouteBuilder {
@Override
public void configure() throws Exception {
from("direct:processOrder")
.split(body().method("getItems"), new OrderItemStrategy())
.parallelProcessing()
.to("direc
浏览 1提问于2017-03-24得票数 1
1回答
目前，我正在使用一个choice()来确定是否打开了窃听队列的切换。在骆驼身上有更好的方法吗？
这是我的密码：
package routes;
import org.apache.camel.builder.RouteBuilder;
public class MyRoute extends RouteBuilder{
private String inQueue;
private String outQueue;
private String wiretapQueue;
private Boolean shouldWiretap;
@Over
浏览 3提问于2015-05-14得票数 1
回答已采纳
骆驼版本: 2.12.2，CXF版本: 2.7，Apache Tomcat: 7
我有以下camel-cxf.xml：
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:s0="http://www.huawei.com/bme/cbsinterface/cbs/businessmgr"
xmlns:s1=
浏览 4提问于2014-08-25得票数 2
回答已采纳
2回答
我是Json Path的新手。我使用Apache camel和json路径。我正在尝试检查json路径成功，以将该值评估为true。
Json消息：
{
"success": true,
"errorMessage": ""
}
Camel Route：
<choice id="_choice1">
<when id="_when1">
<jsonpath suppressExcepti
浏览 2提问于2017-10-25得票数 1
1回答
我有一个camel应用程序，它不能识别路由。这是一个spring boot应用程序。
这是spring boot应用程序类。
我已经定义了yaml文件中的所有属性。但当应用程序启动时，它会显示0/o路由。你知道为什么它能显示出来吗。
我的pom.xml有以下条目。
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XM
浏览 1提问于2020-12-19得票数 0
我们有驼峰路径，它从主题中读取，然后对接收到的消息执行一些转换。
由于其持久主题，一次只处理一条消息，直到路由完成其工作。
为了实现并发，添加了线程池，以便一旦从主题接收到进一步异步工作的消息，线程就会生成，而不是它的顺序线程。就像收到消息一样，线程从池中挑选，并开始处理，直到该线程没有完成处理，下一条消息不会被挑选。
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xml
浏览 0提问于2018-10-25得票数 1
我正在尝试用私钥对JMS文本消息的有效负载进行签名。然后将消息发送到队列并相应地路由。签名将与公钥一起放在消息头中。
我使用下面的代码来使用公钥设置报头。
TextMessage textMessage = session.createTextMessage(message);
String publicKey = new String(pubk.getEncoded());
textMessage.setStringProperty("CamelSignaturePublicKeyOrCert", publicKey);
然而，当消息开始路由时，我会得到以下错误
11:13
浏览 6提问于2013-12-04得票数 0
回答已采纳
当我启动主类时，路由加载文件会自动启动。
在异常时，进程应何时结束。它一次又一次地启动loadfile。
它应该从定时器启动，然后调用loadfile route，但是loadfile是独立于定时器启动的。
CamelContext context = new DefaultCamelContext(sr);
try {
context.addRoutes(new RouteBuilder() {
@Override
public void configure() throws Exception {
浏览 0提问于2020-10-12得票数 0
对于使用聚集生成的文件，我面临java.lang.OutOfMemoryError: GC开销限制。下面是我的路线
<route id="sendToFileRoute">
<from uri="direct:sendToFile" />
<choice>
<when>
<!-- check to ignore if from LIVEFEED -->
<simple&g
浏览 4提问于2015-05-29得票数 1
2回答
我正试着用骆驼做一个程序。这个程序应该能够在一个名为inbox_xml_files.的文件夹中接收xml文件。
然后，程序应该在xml文件中获取< Country >元素节点的文本值。
如果文本值为“丹麦”，则文件应移动到一个名为"outbox_Denmark“的文件夹中。
如果文本值为“瑞典”，则文件应移动到一个名为"outbox_Sweden“的文件夹中。
如果文本值是其他内容，则应该将文件移动到一个名为"outbox_Other“的文件夹中。
这是我用来测试的XML文件：
<?xml version="1.0"?>
浏览 9提问于2017-03-27得票数 3
在过去的几天里，我在没有任何Tomcat或Camel知识的情况下一直在搜索如何做下面的事情，我很惊讶我没有找到任何关于这方面的好资源：
创建一个.war文件，该文件将被部署到Tomcat中(例如，从Manager App)，它将接受给定URI /test上的请求，并将请求转发到在localhost:8222/index.php?q=test上运行的内部服务。
我已经成功地通过在camel-archetype-java之上构建了一个将请求转发到不同url的工作示例，路由器看起来如下所示：
package camelinaction;
import org.apache.camel.builde
浏览 6提问于2020-02-14得票数 2
回答已采纳
这是一个间歇性的问题，大约4/5开始点击空指针。Camel-Context.xml如下所示。
错误：
2011-10-18 08:31:25 245 main INFO MainSupport - Apache Camel 2.8.0在线程"main“中停止异常，从D:\Users\michaelb\workspace\camel-example-spring-eda\target\classes\META-INF\spring\camel-context-NERD.xml；文件解析XML文档嵌套异常是org.springframework.beans.factory.xml.Xm
浏览 2提问于2011-10-18得票数 2
回答已采纳
1回答
这个问题已经问过几次了，但我还是搞不清楚是什么问题。我想使用Apache 2.12.1和Spring3.2.4作为一个独立的Java应用程序运行一个示例应用程序。我正在使用JDK7u25。
以下是我的spring应用程序-config.xml：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchem
浏览 3提问于2013-10-21得票数 0
回答已采纳
回滚事务不起作用。
我试图在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
回答已采纳
我想用XML将Java DSL中的表达式如下： from("direct:a")
.split(body(String.class).tokenize("\n"))
.to("direct:b"); 当我尝试设置时，由两个元素组成，就像这样： <split><tokenize token=\"#@#\"><simple>${bodyAs(java.lang.String)} not contains ''</simple></token
浏览 30提问于2021-02-02得票数 0
回答已采纳
1回答
需要帮助在骆驼中设置变量
、、、
我试图在骆驼代码中设置一个变量，以便在记录路由执行时调用该变量。这个变量需要从xpath语句中设置。
下面是不起作用的代码，我怀疑需要设置一个等于日志消息中的xpath语句的变量，但我不知道该如何做。
<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance&#
浏览 2提问于2014-10-02得票数 0
回答已采纳
为我的英语道歉，太晚了，我很累，没有什么意义
我有大约4项民意调查-丰富的调查文件的位置，每一个石英cron-工作在骆驼。
我每隔10秒进行大约4次投票
// portFolioHoldingsCron = 0/10+*+*+?+*+* )
// the first cron is just evaluates quartz://holdingsRefreshTimer?portfolioHoldingsCron=0/10+*+*+?+*+*
pollEnrich到
from( bridge.components().quartz( "holdingsRefreshTi
浏览 2提问于2014-09-24得票数 1
回答已采纳
我正在实现骆驼路由，在此过程中，我需要在将消息处理重定向到端点(取决于routing slip头)之前放置一个过滤器。如下所示：
from("direct:a")
.routeId("a")
.choice()
.when(header("foo"))
.filter(body().isNotNull())
.routingSlip(header("my-slip&
浏览 4提问于2021-07-28得票数 0
回答已采纳
首先，是的，我已经搜索过了，并且，是的，我已经阅读了每个人都指向的相同的Apache文档。:-)我认为有一点混乱，我想我知道答案，所以让我举一个我认为正确的例子，跟随我认为答案是什么。谢谢。哦，我确实知道有些endChoice()行并不是绝对必要的，Camel会解决这个问题的，但我喜欢清晰地描述这些块，除非有什么理由不使用它们。
.choice()
.when(X1)
// do stuff
.choice()
.when(Y)
//do more stuff
.endCho
浏览 0提问于2015-09-04得票数 19
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
