apache camel - seda端点多播
Apache Camel是一个开源的集成框架，用于在不同的应用程序之间进行消息传递和数据交换。它提供了丰富的组件和路由规则，使开发人员能够轻松地构建和管理各种集成模式。
SEDA（Staged Event-Driven Architecture）是Apache Camel中的一个端点类型，用于实现多播（Multicast）模式。多播是一种消息传递模式，其中一个消息可以同时发送给多个接收者。
SEDA端点多播的优势包括：
- 高性能：SEDA使用事件驱动的方式处理消息，可以实现高吞吐量和低延迟的消息传递。
- 可靠性：SEDA提供了消息队列和持久化机制，确保消息在传递过程中不会丢失。
- 弹性扩展：SEDA可以根据负载情况自动进行扩展，以适应不同的工作负载需求。
- 灵活性：SEDA支持多种消息传递模式，包括点对点、发布/订阅和多播等，可以根据实际需求选择合适的模式。
SEDA端点多播在以下场景中可以发挥作用：
- 分布式系统：SEDA可以用于在分布式系统中进行消息传递和数据交换，实现系统之间的解耦和协同工作。
- 实时数据处理：SEDA可以用于处理实时数据流，例如传感器数据、日志数据等，实现实时监控和分析。
- 异步通信：SEDA可以用于实现异步通信模式，提高系统的响应速度和并发性能。
- 事件驱动架构：SEDA可以用于构建事件驱动的架构，实现系统的松耦合和可扩展性。
腾讯云提供了一系列与Apache Camel相关的产品和服务，包括：
- 云服务器（ECS）：提供虚拟服务器实例，用于部署和运行Apache Camel应用程序。
- 消息队列（CMQ）：提供可靠的消息传递服务，用于在Apache Camel应用程序之间进行异步通信。
- 云数据库（CDB）：提供可扩展的关系型数据库服务，用于存储和管理Apache Camel应用程序的数据。
- 云监控（Cloud Monitor）：提供实时监控和性能分析工具，用于监控和管理Apache Camel应用程序的运行状态。
更多关于腾讯云产品和服务的详细信息，请访问腾讯云官方网站：https://cloud.tencent.com/
相关·内容
我有以下路线 onException(Throwable.class)
.handled(true)
.process(...) --- (A1) Have a shutdown code here.
.rollback();
from("file:D/data/input?fileName=in.txt")
.transacted("required") --- (A2) Have JPA Txn Manager and hikari pooled dataso
浏览 29提问于2020-06-11得票数 0
上下文
我们目前正在使用Apache作为集成框架来设置Springboot项目。
在路由结束时，我们需要使用websocket协议发送消息，其中应用程序充当客户端，需要将消息发送到远程服务器，该服务器公开websocket端点。
但是远程服务器首先需要在WSS握手期间进行身份验证。实际上，它需要一些特定的header，包括Authorization: Bearer {jwt-bearer-token}头。仅在握手时才需要令牌。websocket打开后，不再需要进一步的身份验证。
方法
由于它似乎是Apache的唯一websocket客户端组件，所以我们打算使用，如下面的POM所示：
...
浏览 0提问于2019-06-07得票数 0
回答已采纳
我正在尝试使用fuse esb + apache camel + seda/activemq公开web服务，并且我面临着将状态消息返回到web服务调用的问题。
下面是我的简单骆驼路线：
<?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:cxf=
浏览 8提问于2012-03-09得票数 4
回答已采纳
创建来自各种源的XML输出，这些源需要组合以用于XSLT处理器，但在使用pollEnrich时获得“在端点上没有可用的使用者”。没有传递给pollEnrich交换的pollEnrich聚合器。
取出聚合器并使用默认聚合器。得到相同的问题。添加日志显示，有来自前面到pollEnrich端点的路由的XML输出。
package com.hitrust.route;
import com.hitrust.aggregator.AddToOutput;
import com.hitrust.processor.ConvertResultToRecords;
import org.apache.cam
浏览 0提问于2019-09-06得票数 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
回答已采纳
背景：
在下面的示例代码中，“配置()”方法在指定的时间间隔循环，此时我希望记录当前的"ZonedDateTime.now()“值
问题：
尽管间隔时间不同，ZonedDateTime.now()值始终是相同的值。
问题：
可以使用什么技术在每个间隔访问当前的ZonedDateTime.now()值？
(注:我最终希望将此值用作REST调用中的参数)
样本代码：
package aaa.bbb.ccc.dateparmissue;
import java.time.ZonedDateTime;
import java.time.format.DateTimeFormatter;
im
浏览 2提问于2017-12-27得票数 0
回答已采纳
我使用Apache Camel将请求路由到EJB服务，但我想知道如何设置超时时间？
如果是HTTP服务，Camel HTTP组件可以选择设置超时，但不能设置EJB服务。
浏览 1提问于2014-04-03得票数 1
1回答
我遵循了“骆驼在行动手册”第7章，并实现了一条CXF路线。
<cxf:cxfEndpoint
id="orderEndpoint"
address="http://localhost:9000/order/"
serviceClass="test.order.OrderEndpoint"
wsdlURL="wsdl/order.wsdl" />
<camelContext xmlns="http://camel.apache.org/schema/spring&#
浏览 4提问于2015-06-29得票数 3
回答已采纳
我有多部分文件，首先，我想把它发送到camel管道，并保存这个文件的原始名称。
我的代码：
@Autowired
ProducerTemplate producerTemplate;
...
producerTemplate.sendBody("seda:rest_upload", multipartFile);
另一方面，我有：
from("seda:rest_upload").convertBodyTo(File.class).to("file://rest_files")；
另外，我还尝试使用来注册转换器：
@Converter
浏览 13提问于2017-10-26得票数 5
如何在apache中拆分sql查询的结果?表示，您将得到1000行作为结果，并且希望对它们进行分组处理，例如，1组= 10行。
按照Apache配置使用给定的RECORD_ID查找记录，下一步将迭代第一个查询的结果并运行另一个查询。
例如，如果查询db.query.select.active.record的结果是1000行，那么第二个查询db.query.select.compute.statistics将运行1000x (针对上一次查询的每一行)。由于性能不是最优的，因此我们希望创建一个RECORD_IDs组，例如:首先查询返回1000行，然后将其拆分为100个组(每个组10行)，然后只能运
浏览 1提问于2013-04-30得票数 3
2回答
我无法连接到具有SEDA队列的camel路由。在服务器端，我有以下配置：
<camel:route>
<camel:from uri="seda:input"/>
<camel:log message =">>>>>data is : ${body}"/>
<camel:inOnly uri="activemq:queue:TESTQUEUE"/>
</camel:route
浏览 1提问于2012-05-06得票数 1
回答已采纳
因此，我将文件从本地文件夹移动到sftp位置。这些文件也有可能达到500,000个级别。我有用于写进程的seda，其中多个写入器正在写入文件，但移动文件已成为瓶颈。以下是我目前的骆驼路线：
from(props.splitFolderUri)
.routeId('move-files')
.log(LoggingLevel.INFO, 'file : ${exchange.getIn().headers[\'CamelFileName\']} :: moving this split file to sft
浏览 3提问于2018-05-26得票数 0
1回答
camel和JMX似乎有问题。SEDA JMX组件的一个重要特性是能够使用org.apache.camel->endpoints->COMPNAME/camel->"seda://xyz"...下的get queue方法查看队列大小
但是当使用像这样的东西时
@EndpointInject(uri="seda:closeData?concurrentConsumers=50")
ProducerTemplate producerSymbQueue;
//...
producer.sendBody(object)
//...
在POJO中，JMX
浏览 4提问于2011-07-21得票数 1
回答已采纳
1回答
我使用Camel从Solace队列下载消息，并且很难理解事务管理。
流是这样的，消息从Solace队列下载，然后根据某些逻辑被推送到许多Solace队列中的一个(称为暂存)。从这些暂存队列中，使用SEDA组件将消息路由到处理器(bean)，最后将消息发送到另一个Solace队列。
我已经将事务配置为
<bean id="propagationReqd" class="org.apache.camel.spring.spi.SpringTransactionPolicy">
<property name="transact
浏览 3提问于2016-10-06得票数 0
我正在尝试实现春靴骆驼。我应该创建一个REST，然后REST将把对象/字符串放到ActiveMQ中。我所做的是：
rest("/test/").description("Teste REST Service")
.id("api-route")
.post("/bean")
.consumes(MediaType.APPLICATION_JSON_VALUE)
.produces(MediaType.APPLICATION_JSON_VALUE)
.
浏览 4提问于2019-12-05得票数 0
回答已采纳
1回答
带休息路线的骆驼聚集
、、、
我有一个Camel应用程序，我试图根据来自不同响应(REST服务)的一些输出进行一些聚合。
这就是我到目前为止(骆驼路线)的情况：
@Component
public final class AggregationRoute extends RouteBuilder {
@Override
public void configure() throws Exception {
rest("/aggregation")
.get()
.to("direct:retrieve");
from("dire
浏览 2提问于2016-06-28得票数 1
我们有一个在功能强大的多核服务器上运行的导入器。然而，我们的Apache Camel路由是单线程的，这是一个遗憾。 我们的camel导入器是一个单实例程序。如何让特定的路由使用多个线程处理消息？消息是原子的，由bean处理，它已经以线程安全的方式完成了这项工作。如果我可以在线程中处理批处理(maxMessagesPerPoll)，并且在下一次轮询发生之前有空闲时间，我已经很高兴了(毕竟，这仍然比顺序处理要好)。 下面是我想要实现多线程的一条路径： public void onConfigure() throws Exception {
// This is a JPA query w
浏览 35提问于2019-01-14得票数 0
回答已采纳
3回答
普通队列与SEDA队列
、、、
作为Apache Camel的新手，我最近查看了它的长长的组件列表，偶然发现了它们对组件的支持。
这个页面对我来说没有多大意义，所以我在网上搜索了几次"SEDA queue“，得到了维基百科上的文章。
读完那篇文章后，我不知道SEDA队列和普通的“普通”队列有什么不同！两者都包含通过使用异步队列来解耦系统的概念。
在这篇文章中，"SEDA“听起来就像是一个架构，它包含了在每个组件之间放置一个队列。这是正确的吗？
但是如果它只是一个架构，那么为什么"SEDA“队列是一个特殊的Apache Camel组件呢？
浏览 2提问于2012-02-06得票数 15
回答已采纳
我有我正在工作的骆驼路线。该路由将CSV文件从sftp中的一个目录带到sftp中的另一个目录，同时执行到XML的转换。
from(mySftp.getUri("/camel"))
.choice()
.when(body().isNull())
.log("No Files Found")
.otherwise()
.process(new Processor() {
StringBuilder sb = new StringBuilder();
浏览 4提问于2018-03-15得票数 0
2回答
我有一个带拆分器的驼峰路由(使用流)，它将消息发送到seda队列进行处理。当我试图轻轻地停止应用程序时，seda队列不会立即停止，它正在处理所有消息，最后关闭。我能做些什么来立即阻止它？
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.TimeUnit;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.ca
浏览 2提问于2013-05-27得票数 3
回答已采纳
我在spring boot上使用jboss fuse/camel 2.11，这是一个带有静态uri的seda组件，用于为seda设置队列大小，以下是示例：
camel-context1.xml：
<to id="_toPreProcessor" uri="vm:request-preprocessor?size={{rest.queueSize}}"/>
camel-context2.xml：
<from id="_preprocessor-from" uri="vm:request-preprocessor"/
浏览 2提问于2018-07-11得票数 0
1回答
我是Camel的新手，正在尝试设置一个非常简单的应用程序来适应它，我正在运行以下代码：
CamelContext cc = (CamelContext)ac.getBean("testCamelContext");
ProducerTemplate template = cc.createProducerTemplate();
System.out.println("Sending Message Body");
template.sendBody("seda:testProducer", "hello");
System.out
浏览 1提问于2012-11-23得票数 0
回答已采纳
我在Camel DSL中使用组播，因为我需要将同一消息的副本发送到两个不同的端点。但是，这两个路由似乎相互干扰。我是不是搞错了语法，或者其他问题？
from("{{in.endpoint}}")
.routeId(this.getClass().getSimpleName())
.multicast().parallelProcessing()
.to("{{update.in}}", "{{add.ibmmq.topic}});
哪里
in.endpoint = seda:addOrder?waitForTaskToCo
浏览 2提问于2013-12-03得票数 1
1回答
我正在尝试从属性文件中读取时间延迟。
已在我的属性文件中定义：
time_inMilis=15000
我已经将camel上下文xml配置为：
<bean id="property" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="locations">
<value>file:/D:/Develop/resources/m
浏览 0提问于2014-10-20得票数 1
我在下面的h2数据库1.4.197中遇到一个错误。基本上，我试图在记录被处理后立即更新它。
我没有使用insert，而是使用merge语句，因为我不想要重复的记录。下面是我的问题：
merge into tableName key(col1,col2) values(?,?,?);
我使用连接池，并将最大连接池设置为100，通过调试，我发现错误是按随机顺序抛出的。话虽如此，当第1000条记录被插入时，第一次抛出错误。在第二次执行时，它发生在554个记录中。
这是我的connectionstring：
jdbc:h2:file:" + DB_NAME + ";MV_STORE=t
浏览 4提问于2018-04-02得票数 2
我有一个很大的问题，我不能理解。
我有一个具有xquery转换的驼峰路由：
<transform>
<xquery>resource:file {{choregraphies.resources.directory}}/LINCASA1/xquery/getTypApr_request.xquery
</xquery>
</transform>
我把你放进了getTypApr_request.xquery文件
xquery version "1.0";
declare namespace xs=
浏览 0提问于2018-05-29得票数 0
应用程序信息：
下面的代码:从IBM队列读取，然后将消息发布到REST服务
从MQ队列读取(note：是一个快速的问题，并且不是的问题-而是post操作性能我在改进中遇到了问题).
问题：
每秒无法输出或发送超过44-47条消息.
问题：
如何提高以下JbossFuse (v6.3) DSL路由代码的性能？(有哪些技术可以使它更快？)
package aaa.bbb.ccc;
import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.cdi.C
浏览 1提问于2017-11-16得票数 0
我有一个seda队列，根据queueSize设置选项
我的路线看起来是：
from("seda:someQueue?concurrentConsumers=10&queueSize=10")
.process(someProcessor);
由于queueSize选项，我得到了以下错误：
org.apache.camel.FailedToCreateRouteException:未能创建route....bla bla bla.有1个参数无法在端点上设置。如果参数拼写正确，并且它们是端点的属性，请检查uri。未知parameters={queueSize=10}堆栈跟踪
浏览 0提问于2017-10-13得票数 1
回答已采纳
1回答
我在应用程序中使用camel和cxf。有一个新的模块，它具有赏金城堡依赖org.bouncycastle:bcprov-jdk15on:jar:1.53。添加此模块后，我开始在运行时获得异常：
21-Dec-2015 12:02:06.194 INFO [Camel (camel-1) thread #17 - seda://sp-tsm:handleEndServiceChangeNotification] org.apache.catalina.loader.WebappClassLoaderBase.checkStateForResourceLoading Illegal access:
浏览 2提问于2015-12-22得票数 1
我有一个用例，在这个用例中，我希望使用apache路由到S3在内存中写入Java阻塞队列内容。这可能吗？？
我能想到的解决办法是从阻塞队列中提取记录，然后刷新到本地文件，然后通过文件- S3路由发送到S3。
更新：
路线：
fromF("seda:awsquue?concurrentConsumers=3&queue=#NonLimitQueue%s", getSourceId())
.convertBodyTo(byte[].class)
.setHeader(S3Constants.CONTENT_LENGTH, simple("${
浏览 4提问于2021-12-10得票数 0
我试图在apache camel中使用循环来处理从数据库中获得的一些数据，以防内存耗尽。但是，在处理完所有数据之后，我需要将它们写到一个文件中，所以我使用".end()“来结束循环，并使用.to()来另一个路由来写到文件中，但是似乎最后一步也在循环中，它已经被写到文件中好几次了。
from("seda:start")
.loopDoWhile(header("loopflag"))
.to()//handle data
.end()
.to("seda:generateFile");
from("seda:generateFil
浏览 0提问于2019-08-21得票数 0
我得到了camel (3.5.0)应用程序的弹簧引导(2.3.2.RELEASE)和两个测试路线：
这样做的目的是检查从多播调用的子路由异常发生时会发生什么，以及它如何处理事务。
@Component
public class MyRoute1 extends RouteBuilder {
@Override
public void configure() {
onException(Exception.class)
.useOriginalBody()
.log("Error handler parent. Body is: ${body}
浏览 1提问于2020-11-03得票数 10
问题：
我正在使用JBoss Fuse和camel-netty4-http发布到REST服务。
-How我会获得其余的返回代码--也就是“状态代码”--(为了记录它)？
示例代码：
@Override
public void configure() throws Exception {
...
from("wmq:queue:mylocalqueue")
.log("inMessage=" + (null==body()?"":body().toString()))
.to("seda:node1?concurren
浏览 5提问于2017-11-27得票数 0
回答已采纳
我是阿帕奇骆驼的新手。我已经将我的应用程序设置为使用基于XML的配置的Apache。我的配置包含具有类似步骤集的多个路由。我试图找出一种方法，将这些不同路线的公共部分或重复部分放置在一个地方，并从路线中引用它们，而不是一次又一次地重复它们？
例如，在我下面的骆驼路线配置中，路线2是重复路线1的几个步骤，那么有没有办法提取路线1和路线2的共同步骤，然后引用从路线1和路线2提取的部分？
<context:property-placeholder location="classpath:quartz.properties" />
<context:componen
浏览 0提问于2014-01-06得票数 0
回答已采纳
使用Apache Camel，我有一个路由，它获取一个文件，通过一个bean详细描述它，然后将它发送到一个seda队列。如果没有人从该队列中消费，则文件上的锁将保留。在这种情况下有可能释放锁吗？我刚刚尝试了"discardIfNoConsumers=true“作为seda选项，但不起作用。
我会给你看我的路线：
from(loadInputUri())
.split()
.tokenize(getLineSeparator(), getBatchSize())
.streaming()
.s
浏览 0提问于2016-03-11得票数 1
1回答
阿帕奇骆驼动态消费者
、、、
我创造了这条骆驼路线
from("direct:pageExtraction")
.bean(PageManager.class, "setProperties(*, ${headers})")
.filter().method(PageManager.class, "exists").to("seda:pagePostProcessing").end()
.to("seda:pageImposition");
fro
浏览 1提问于2015-07-21得票数 4
我有以下路由定义：
@Component
public class CamelRoutes extends RouteBuilder {
@Override
public void configure() throws Exception {
from("seda:second")
.bean("helloWorld?method=smth")
.process(exchange -> {
浏览 0提问于2017-10-24得票数 4
回答已采纳
我使用cxf通过camel路由调用cxf服务。
Camel Route：
....
.to("cxf:bean:UWServiceProxy")
....
我的CXF Bean条目如下-
<cxf:cxfEndpoint id="UWServiceProxy"
address="http://sqdsql:8001/FirstGen/services/UWWebServiceProxy.UWWebServiceProxyHttpSoap11Endpoint/"
endpointName="c:UWW
浏览 7提问于2014-09-12得票数 1
我一直在尝试让Camel Netty4 udp组播在windows上工作，而NettyUDPMulticastAsyncTest似乎在java.nio.channels.ClosedChannelException上失败了。同样的测试似乎也在OSX上进行。这两台机器都在运行Java1.7，我已经在测试中更新了接口名，并且能够在同一个接口上运行一个NIO多播示例。我正在使用Camel 2.14.1，但它似乎也不适用于2.15.x。
堆栈跟踪在下面。
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.026 sec
浏览 4提问于2015-06-29得票数 0
回答已采纳
我使用Camel从Amazon队列中读取消息，进行一些CPU密集型处理，然后将它们放到另一个SQS队列中。Camel是通过使用mvn camel:run的maven插件调用的。
当运行在具有多个核的服务器上时，Camel似乎只使用单个内核来处理消息(通过监视所有内核的CPU利用率来观察)。如何利用所有可用的核心？
我尝试过的事情：
运行JVM的多个实例(例如，并行运行多个mvm camel:run作业)。这是可行的，但似乎并不理想。
在使用者上设置maxMessagesPerPoll=10。并没有起到什么作用。
有关路线：
<route id="marc
浏览 0提问于2014-10-02得票数 1
回答已采纳
我试着在骆驼蓝图中测试骆驼蓝图-测试。这条路线可以在空手道上装载，在使用骆驼和春天的时候也可以使用。在这一点上，我得到：
org.apache.camel.FailedToCreateRouteException: Failed to create route route1 at: >>> Unmarshal[ref:IssRequest] <<< in route: Route(route1)[[From[seda:from_rraa]] -> [process[ref:issPrep... because of Data format 'j
浏览 2提问于2015-10-12得票数 0
回答已采纳
我们正在使用Apache集成平台，并通过restlets更新一些数据。我们想知道这个更新的状态，因为它需要几个小时才能完成。我们面临的问题是，在程序完成之前，我们无法从程序中得到响应。因为载体类型是restlet类型，所以我们必须等待作业完成，因为浏览器正在等待它完成。我们已经研究过异步的方法，但似乎restlet数据载体不支持异步。
如果我们没有得到任何解决方案，我们已经考虑过使用线程池运行作业，但是我们想知道是否还有其他方法来执行作业异步，因为稍后我们可能会更广泛地使用camel restlet，而让作业不每次执行线程就更好了。
示例代码：
from("restlet:"
浏览 2提问于2017-04-24得票数 0
回答已采纳
我是Apache Camel的新手。我正在尝试在Apache Camel中将报头与请求正文一起发送到路由。
// headers is a map
APIResponse response = (APIResponse) producer.requestBodyAndHeader("direct:route1",body,headers);
我收到以下错误：
java.lang.IllegalArgumentException: defaultEndpoint must be specified
at org.apache.camel.util.ObjectHelper
浏览 0提问于2018-12-12得票数 1
1回答
我正在尝试使用camel代理和Java接口调用一个直接端点。我将此接口作为OSGI服务公开给另一个捆绑包，并访问该捆绑包中的接口。一切都运行得很好，现在我得到了一个需求，需要在相同的camel上下文中使用相同的接口根据特定条件调用另一个直接端点。我该怎么做呢？
Camel routes:
<camelContext id="cContext" trace="false" xmlns="http://camel.apache.org/schema/blueprint">
<proxy id="ca
浏览 0提问于2014-09-03得票数 0
1回答
我有一个场景，我使用camel-restlet组件接收post请求，我将这些请求转发到外部web服务，在从外部服务收到响应代码后，我需要将此响应代码添加到我自己对客户端的异步响应中。
我正在尝试将响应对象保存到hashMap，其中密钥是根据请求内容生成的唯一序列号，一旦收到来自外部web服务的响应，我就可以使用此唯一密钥从hashMap检索响应对象。看起来restlet将响应保存到exchange.getOut()消息并同步地发送回客户端，这不是我想要的。不设置out消息会给我一个nullPointerException。
路由类：
public class ReceiveRoute exte
浏览 3提问于2018-08-30得票数 1
1回答
在尝试使用Apache camel聚合策略时，我遇到了如下所述的问题：
我的应用程序:公开一个简单的soap服务，该服务包含组织中部门的名称(财务、销售.)。在我的骆驼路线内，我相应地将请求路由到部门特定的路线。在这些路径中，我查询一个表，并为该部门获取员工。
作为soap服务的响应，我希望将所有员工聚集在一起并发送。
下面是我的骆驼路线：
<camelContext id="camel"
xmlns="http://camel.apache.org/schema/spring">
<camel:dataFormats>
浏览 0提问于2018-04-10得票数 1
回答已采纳
我正在尝试在Camel2.23.2中设置一个自定义的processStrategy。我尝试了几种从processStrategy uri parameter引用它的方法，但我总是得到这样的异常： Caused by: java.lang.IllegalArgumentException: Could not find a suitable setter for property: processStrategy as there isn't a setter method with same type: java.lang.String nor type conversion pos
浏览 70提问于2021-10-28得票数 0
我目前在我的路由中使用doTry/doCatch块，因为我不能使用全局onException块。
但是，如果camel路由中断(由于糟糕代码或意外/未测试的场景)，我希望执行一些业务逻辑。希望这种情况永远不会发生，但我仍然想处理更糟糕的情况。
我不能在全局onException块中有一个java.lang.Exception，而且，我不想在每个路由上都放一个额外的catch。
在抛出未捕获的异常和中断路由之前，是否有一个特定的方法来调用Camel。
对于未捕获的异常，我看到以下日志：
2015-04-20 15:11:35,279 [Camel (fulfillmentOrderProcess
浏览 12提问于2015-04-21得票数 0
1回答
在下面的camel上下文中，我使用提供的ArrayBlockingQueue配置了一个SEDA端点
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="
http://www
浏览 0提问于2016-06-03得票数 1
回答已采纳
2回答
我使用Camel路由通过activemq队列发送xml消息。消息正在到达队列，但它无法读取它。不确定是apache camel问题还是活动MQ问题。我的骆驼路线是
<route>
<from uri="seda:elixirBatchQueue" />
<inOnly uri="activemq:queue:TESTQUEUE"/>
</route>
队列中的错误消息是
javax.jms.JMSException: Failed to build b
浏览 1提问于2012-05-24得票数 0
回答已采纳
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
腾讯云开发者
