Java camel路由永远不会到达Java语句
Java camel路由是指使用Apache Camel框架进行消息路由和集成的过程。该框架基于企业集成模式（Enterprise Integration Patterns）和路由引擎（routing engine）的思想，可以用于构建可靠的、高性能的应用程序。
在Java camel路由中，消息通常通过终端（endpoint）进行输入和输出。路由定义了消息从一个终端到另一个终端的路径，并可以应用多种模式对消息进行转换、过滤、验证、转发等操作。Java语句是指在路由中使用Java编程语言编写的语句，用于实现特定的业务逻辑。
由于Java camel路由是基于Apache Camel框架的，所以腾讯云并没有直接相关的产品。然而，腾讯云提供了一系列云计算和中间件产品，可以与Java camel路由进行结合使用，以满足不同的应用场景。
以下是一些腾讯云产品和相关链接，可以与Java camel路由结合使用：
- 腾讯云消息队列 CMQ：可用于在路由中进行消息的存储和传递，提供高可用、高可靠的消息传递服务。产品链接：腾讯云消息队列 CMQ
- 腾讯云云函数 SCF：可以作为路由中的终端，用于触发和执行特定的业务逻辑。产品链接：腾讯云云函数 SCF
- 腾讯云数据库 CDB：可以作为路由中的数据源，用于存储和管理应用程序的数据。产品链接：腾讯云数据库 CDB
- 腾讯云容器服务 TKE：可以用于部署和管理路由中的应用程序容器，提供高可用、可扩展的运行环境。产品链接：腾讯云容器服务 TKE
请注意，以上产品仅作为示例，实际选择产品时需要根据具体需求进行评估和选择。同时，还可以结合腾讯云的网络、存储、安全等其他产品来构建完整的云计算解决方案。
相关·内容
我正在学习一些教程，以了解如何在已部署的Jboss EAP6.4服务器上使用camel路由。我当前应用程序的目标相当简单，因为我想从ActiveMQ主题中读取内容，然后将其注销。下面的代码总结了我的操作：
package com.mycompany;
import javax.ejb.Startup;
import javax.enterprise.context.ApplicationScoped;
import javax.jms.ConnectionFactory;
import org.apache.activemq.ActiveMQConnectionFactory;
impor
浏览 0提问于2017-09-14得票数 0
1回答
我在InOut模式中有多个顺序队列，每个队列导致一个Camel处理器。如果处理器需要太多的时间来进行治疗，我希望请求回复检测超时并发送一个ExchangeTimedOutException。CamelJmsRequestTimeout的超时工作，但只适用于第一个队列。
例如，如果我有这样的例子：
q1 -> p1 -> q2 -> p2 -> q3 -> p3
例如，q1 CamelJmsRequestTimeout就是5s。如果每个处理器使用3s (我用take ()模拟处理器中的延迟)，我将在p2上有一个超时，因为总时间是6s。为什么对q1的回复不是在p1之
浏览 0提问于2019-08-02得票数 0
我正在开发一个简单的处理器来验证路由中是否存在强制属性。在调用处理器之前，我需要将该列表添加到路由定义中。
<route id="test1">
<from uri="/v1/test1" />
<setProperty propertyName="mandatoryProperties">
<simple resultType="java.util.List">${[A,B,C]}</simple>
浏览 2提问于2018-03-08得票数 0
1回答
我无法解决这个错误，它总是在网上说“无法到达的语句”：
int row = e.getFirstRow()
它建议拆分声明，但即使在此之后，"e.getFirstRow()"行上的错误仍然是一样的：
import javax.swing.event.TableModelEvent;
import javax.swing.event.TableModelListener;
import javax.swing.table.DefaultTableModel;
import javax.swing.table.TableModel;
public class View exte
浏览 2提问于2015-07-15得票数 0
我得到了这段java代码，出于某种原因，编译器在writer.println(linestr);上提取了一个错误；错误：(51，13) java:无法访问的语句
String linestr ="";
int row = 1, col = 1;
PrintWriter writer = new PrintWriter("C:\\Users\\User\\Selenium\\scrapjv\\output\\out.txt", "UTF-8");
while(isElementPresent(By.xpath("//div[@id='
浏览 3提问于2014-08-31得票数 1
回答已采纳
我目前在我的路由中使用doTry/doCatch块，因为我不能使用全局onException块。
但是，如果camel路由中断(由于糟糕代码或意外/未测试的场景)，我希望执行一些业务逻辑。希望这种情况永远不会发生，但我仍然想处理更糟糕的情况。
我不能在全局onException块中有一个java.lang.Exception，而且，我不想在每个路由上都放一个额外的catch。
在抛出未捕获的异常和中断路由之前，是否有一个特定的方法来调用Camel。
对于未捕获的异常，我看到以下日志：
2015-04-20 15:11:35,279 [Camel (fulfillmentOrderProcess
浏览 12提问于2015-04-21得票数 0
在下面的驼峰路由中，spring DSL中有try和finally块，如果有404Http状态代码，则控制不会到达finally块。这是因为预期finally块应该得到执行，而不管try中的任何预期或错误返回的响应是:org.apache.camel.component.http.HttpOperationFailedException: block.The操作调用localhost:8080/ returned.Why失败
<camel:doTry>
<from uri="http://localhost:8080/testTr
浏览 3提问于2014-08-26得票数 0
3回答
我正在学习Java中的异常，在这个示例中我面临一个编译错误：
public class FinallyExceptionExample {
public static void main (String[] args) throws Exception {
try {
System.out.println("1");
throw new Exception();
} finally{
System.out.println("3");
}
浏览 0提问于2018-09-13得票数 1
回答已采纳
我试图调用camel/java/class(这是很长的程序，所以没有时间转换)。因此，目前的解决方案是从spring启动开始，然后调用主类。
这里是springboot的主要应用程序，它将调用javaee/class，我之前尝试过简单的bean调用，所以这是我最近的一次测试，因为我想到了正确的bean调用，但是不幸的是，即使是正确的bean调用也与简单的bean调用一样错误，
@SpringBootApplication
public class App {
public static void main(String[] args) throws Exception {
浏览 27提问于2022-08-17得票数 0
我想知道为什么当路由上设置了"transacted“时，我会得到以下异常。
errorHandler(deadLetterChannel("activemq:EXCEPTION")
.useOriginalMessage()
.maximumRedeliveries(1));
from("activemq:TRIGGER").routeId("Trigger")
.transacted()
.bean(&#
浏览 2提问于2015-12-04得票数 0
寻找一些帮助来处理在上下文中启动camel路由期间可能发生的错误条件。我们正在使用java dsl在读取配置后创建路由。当其中一个配置错误时(例如，sftp uri中缺少主机名。错误的运行时发现)，所有后续路由甚至不是由camel启动的。我们试图实现的是，记录故障情况的错误，并继续后续路由。
有没有类似的拦截器？
浏览 1提问于2014-11-18得票数 0
1回答
我们在应用程序中使用apache camel和JBOSS fuse进行集成。我们在一个捆绑包下构建了近80个API，并且camel上下文包含100+路由。
当我们在JBOSS fuse上部署捆绑包时，所有路由几乎需要1个小时才能启动并运行，而捆绑包在部署了1个小时后就“启动”了。我们可以将捆绑包分成几个部分，假设每个捆绑包最多有10个API，但我们已经在一个捆绑包中开发了我们的应用程序，并且它消耗了如此多的启动时间。
除了将捆绑包拆分成更小的捆绑包之外，还有什么方法可以减少捆绑包“启动”的时间吗？
浏览 0提问于2018-06-21得票数 0
我们正在使用Apache Camel实现一个Web服务，它有许多(20-50)个“直接：”路由调用Java方法。无论是用于业务规则处理还是DAO访问方法，每个方法基本上都有一条路径。所有路由都使用from("direct:").to("direct")，但从不使用任何其他组件。
虽然这看起来像是将系统与标准的Controller->bo->dao层解耦，但它增加了对Camel路由的不必要的记账。
一种更好的替代方法是简单地为业务对象和Dao层定义Java接口，并为任何其他服务(系统外部，如file://或http://)请求定义一个附加接口，这些请求
浏览 1提问于2016-09-19得票数 0
首先:我是Apache Camel和Stack Overflow的新手！
我已经创建了一条从SFTP服务器过滤和下载文件并在处理后删除这些文件的路由。
我的问题:在我的本地计算机上，路由工作得很好。当我在生产服务器上部署这个路由(相同的.war)时，下载可以正常工作，但是当FTP组件试图删除文件时，我得到下面的异常。开发和生产的机器有相同的camel，tomcat和java版本。唯一的区别是操作系统(开发人员: Windows 7，产品: Windows Server2008 R2)
有什么想法吗？
java.lang.IllegalArgumentException: Resolving l
浏览 2提问于2014-08-08得票数 4
使用camel.springboot.xml-rests = classpath:folder- Camel /folder- rest /*.xml属性中定义的XML路径，通过“XML-rest”将rest定义加载到camel Spring Boot 3.2时出现此错误 我的rest定义文件如下所示 <?xml version="1.0" encoding="UTF-8"?>
<rests xmlns="http://camel.apache.org/schema/spring" xmlns:xsi="http://
浏览 44提问于2020-04-26得票数 3
回答已采纳
我们有一个提供SOAP服务的Apache Camel应用程序。“初始路由”从Apache CFX -provided端点开始。
我们需要一种简单的机制来防止消息被“过快”地处理(并且没有大规模的可扩展性需求)。
因此，我们最终尝试了。现在，问题是在给我们的路线增加油门后，有些地方出了问题。
最初的路线，有些干净：
from("cxf:bean:sapEndpoint").routeId(SOAP_ENDPOINT)
.throttle(1)
.onException(Exception.class)
.to("direct:emailFa
浏览 2提问于2013-02-18得票数 0
我想运行一次路由，并在路由完成时停止上下文。目前，我在主Java类中执行通常的Thread.sleep(3000)，以便为路由完成留出一些时间，但这显然是不准确的，我的路由可能需要1秒或20秒，我不能提前知道。
Java类：
public static void main(String[] args) throws Exception {
try (ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("camel-context.xml")) {
Came
浏览 2提问于2015-06-25得票数 0
通常，如果我们使用java DSL开发Java camel应用程序，那么很难监控camel路由。为了检查路由是否正在运行，我们需要开发一个额外的监控应用程序。
但是Hawtio在这方面简化了我们的工作。如果您的项目是web应用程序项目，则Hawtio已经为其提供了camel组件。因此，不需要任何额外的努力，它就可以直接工作。
但对于Java应用程序，它不会显示路由。
浏览 2提问于2018-02-10得票数 5
我正在我的spring Boot，Camel应用程序中测试Spring安全性。当我尝试使用自动连接的ProducerTemplate测试路由时，抛出异常并显示消息"No consumers on endpoint: direct://secure“。在camel上下文中正确定义了路由。
RouteBuilder代码：
@Component
public class SpringSecurityRoute extends RouteBuilder {
protected Logger logger = LoggerFactory.getLogger(SpringSecurityR
浏览 5提问于2017-01-19得票数 3
我有很多选择，但这条路只适用于最后一种情况。在其他情况下，路线会被卡住，不会继续前进。
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
回答已采纳
在下面的路由中，当我们得到异常时，将忽略来自redeliveryPolicy的redeliveryPolicy clausule。我们得到：
未能交付(MessageId: ID-UW205584-58231-1527668174534-39-248 on ExchangeId: ID-UW205584-58231-1527668174534-39-24).送货企图:0
未能交付(MessageId: ID-UW205584-58231-1527668174534-39-248 on ExchangeId: ID-UW205584-58231-1527668174534-39-24).送货企图
浏览 1提问于2018-05-30得票数 0
我正在编写http requests.and终结点的通用路由不是路由的静态value.Code：
from("direct:processRequests")
.split(body().method("getItems"), new GroupedBodyAggregationStrategy())
.parallelProcessing()
.to("direct:processRequest")
.end();
浏览 0提问于2017-09-13得票数 0
我创建了一个拦截器来测试Camel路由中的异常处理程序。这是一个拦截器： context.getRouteDefinition("AnalisingResponse").adviceWith(context,
new AdviceWithRouteBuilder() {
@Override
public void configure() {
interceptSendToEndpoint("direct:PsMessageLogger_upd
浏览 166提问于2020-08-23得票数 0
回答已采纳
1回答
客户端soap故障处理
、、、
我使用camel和cxf组件从web服务中获取一些数据。在某些情况下，web服务返回标准soap:故障。我还有接下来的步骤：
<camel:route id="someId">
<camel:onException useOriginalMessage="false">
<camel:exception>java.lang.Exception</camel:exception>
<camel:handled>
<
浏览 2提问于2013-08-14得票数 0
回答已采纳
我想聚合3个主题，但只是为了聚合策略的PoC，我尝试聚合2个主题。 因此，我已经配置了以下Camel路由： @Override
public void configure() throws Exception {
CamelContext contexto = new DefaultCamelContext();
try{
onException(SQLException.class, Exception.class)
.handled(true)
.maximumRedeliveries(1)
.process
浏览 44提问于2020-08-15得票数 1
回答已采纳
我首先知道这个问题是假的，但我却找不到关于文档的内容。让Apache扫描远程HBase上的表的方法是什么？
阿帕奇骆驼的帮不了什么忙。它只在本地安装hbase时才能工作。
提前行动！
编辑：
我尝试了@cexbrayat的例子，但是我得到了下面的例外。
8071 [Camel (camel-1) thread #1 - stream://in] ERROR org.apache.camel.processor.DefaultErrorHandler - Failed delivery for (MessageId: ID-1344429030688-0-1 on ExchangeId: ID-
浏览 5提问于2012-08-07得票数 0
我正在尝试配置spring事务策略
<bean id="transactionManager" class="org.springframework.transaction.jta.WebSphereUowTransactionManager">
</bean>
<bean id="PROPAGATION_REQUIRED" class="org.apache.camel.spring.spi.SpringTransactionPolicy">
<property na
浏览 3提问于2015-08-27得票数 0
1回答
我有一个简单的例子，我使用多播与3个bean。that返回一个RuntimeException，但这很好，因为它不阻止将响应返回给客户端(servlet调用)。但是，如果我在from和组播之间添加了一个dynamicRouter，那么就不会返回更多的响应，而Camel试图通过将消息重发到多播来处理异常。这会导致转换异常，因为在我的聚合器中，我修改in消息。
如何保持相同的行为并使用dynamicRouter？
谢谢
下面是一些我正在使用的文件的摘录：
camel.xml
<!-- Generic route listening to all the the requests --
浏览 2提问于2013-06-07得票数 0
回答已采纳
3回答
我正在为SmartFox服务器扩展创建一个Java类。它正在尝试访问MySQL数据库。
我在session.setProperty("DatabaseID", dbId);行上收到一个名为Unreachable Code的错误
package sfs2x.extension.test.dblogin;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import com.smartfo
浏览 1提问于2013-02-22得票数 3
回答已采纳
Java - Apache Camel 2.17 JAVA DSL
我的路由处理数据并返回它处理的日期，我希望将从List<LocalDate>返回的myBean.processData传递给日志并设置为标头。
以下是我的代码
from("route1")
.bean("myBean","processData")
.log("how do i log the response of processData return")
. setHeader("processDataReturnValue") /
浏览 15提问于2017-06-05得票数 0
回答已采纳
2回答
我写了一小块骆驼来消耗一个ftp服务器。
但是在运行了一段时间之后，它会抛出一个异常，继续运行，但是不再消耗任何东西。另外，当我再次启动它，并且有更多的文件等待被消耗时，它将再次崩溃。我已经添加了一个异常处理程序，但是看起来is并没有捕获异常。
这是我收到的例外：
Caused by: [org.apache.camel.component.file.GenericFileOperationFailedException - File operation failed: 150 Opening ASCII mode data connection for 2386442.XML(3895 by
浏览 7提问于2012-07-05得票数 3
我在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
回答已采纳
因此，我有一个从一个队列中使用JMS消息的路由，我希望将它发送到同一个代理上的另一个队列。蓝图xml非常简单：
<camel:route id="from-jms-consumer-to-jms" trace="false">
<from uri="jms:queue:test" />
<log message="Message consumed :: ${body}" />
<to uri="jms:queue:other_tes
浏览 0提问于2019-08-15得票数 0
你好!
我正在尝试用Java和RouteBuilder实现骆驼路由。我想从定时器端点发送到cxf端点。
代码：
public class MyRoute extends RouteBuilder {
@Override
public void configure() {
CamelContext camelContext = getContext();
CxfEndpoint cxfEndpoint = new CxfEndpoint();
cxfEndpoint.setAddress("ht
浏览 3提问于2014-03-18得票数 5
回答已采纳
1回答
我在骆驼中的routeContext中定义了一个简单的路由(这个路由将用于多个路由)。
<route id="sendToRabbitQueue">
<from uri="direct:sendToQueue" />
<convertBodyTo type="java.lang.String"/>
<setHeader headerName="rabbitmq.ROUTING_KEY">
<cons
浏览 5提问于2015-09-03得票数 5
回答已采纳
我想向csv编组传递一个动态分隔符，如下所示。
<marshal>
<csv delimiter="${header.FIELD_DELIMITER}"/>
</marshal>
当我像上面那样尝试时，我得到了这个异常：
Caused by: java.lang.IllegalArgumentException: Delimiter must have a length of one!
at org.apache.camel.model.dataformat.CsvDataFormat.configureDataFormat(
浏览 1提问于2015-07-07得票数 1
2回答
我有一个Spring DSL路由，如下：
<bean id="sendMsgProc" class="com.tc.infrastructure.utils.jms.SendMessageProcessor"/>
<camel:camelContext id="folder-jms" xmlns="http://camel.apache.org/schema/spring" autoStartup="false">
<camel:propertyPlacehold
浏览 0提问于2014-12-02得票数 3
我有一个驼峰路由，它会自动调用，直到满足特定的条件。其基本思想是实现路由的重试。当部署应用程序时，当重试发生很长一段时间时，我会收到堆栈溢出错误。
[Camel (camel-1) thread #1 - Multicast] ERROR com.application.RouteName.lambda$configure$0 - Exception occurred during execution on the exchange: Exchange[ID-batchrater-310822922-1-383133832-34058-1530798326741-0-6]
or
浏览 6提问于2018-07-10得票数 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
我在用
Spring Boot 1.5.10.RELEASE
Camel 2.21.1
Java 1.8
我的申请
@SpringBootApplication
@ImportResource({"classpath:my-webservice.xml", "classpath:my-camel.xml"})
public class CamelCXFApplication extends SpringBootServletInitializer {
public static void main(String[] args) {
Sp
浏览 1提问于2018-06-25得票数 1
回答已采纳
2回答
在单元测试中，我想模拟Exception的发生。
由于doTry/doCatch-block，我希望在"mock:count“端点收到一条消息。为什么没有发生这种情况，为什么Exception由通用onException-block处理？
import org.apache.camel.LoggingLevel;
import org.apache.camel.builder.AdviceWithRouteBuilder;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mo
浏览 1提问于2013-11-18得票数 3
回答已采纳
我很难获得一个简单的cxf:rsServer来监听端口。
我的appContext：
<bean id="transformer" class="com.xyxx.portlistener.services.Transformer">
</bean>
<cxf:rsServer id="pushServer"
address="tcp://localhost:9090/hrm/hrm_push?bindingStyle=SimpleConsumer;resourceClass
浏览 3提问于2014-01-17得票数 2
回答已采纳
我有一个spring引导应用程序app.jar，它使用Apache Camel来集成主机。目前，XML路由和自定义camel JAVA类(处理器)都打包在spring boot应用程序中。我的需求是将XML路由和自定义camel处理器移到spring boot jar之外，以便在部署期间用户可以编写自己的自定义XML路由和处理器。我能够使用camel.springboot.routes-include-pattern = file:${workdir.path}/camel/routes/*.xml将XML路由外部化，并在workdir/camel/libs/中创建了一个jar (使用gra
浏览 40提问于2021-10-27得票数 0
我正在做一个将XML值插入Oracle数据库的概念证明。我在Java中使用StringBuilder来插入值。我的Camel上下文是：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
浏览 3提问于2014-09-05得票数 0
我对骆驼http请求有以下问题。我希望保留url查询字符串参数的值，而不将其传递给需要在路由上执行的另一个http请求。在http请求外部api处理数据后，需要该值。以下是对这个问题的澄清：
rest("/api")//We get requests as /camel/api?param1=xyz...
.get()
.route()
.setHeader(Exchange.HTTP_METHOD, constant("GET"))
.setHeader("Accept-Encoding"
浏览 1提问于2021-01-30得票数 1
回答已采纳
import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;
public class ReadFileExample {
public static void main(String [] args) throws Exception{
System.out.println("trying to copy file");
CamelContext ctx
浏览 2提问于2016-04-05得票数 1
这是我编写的从队列中读取消息的类。
public class Sender {
public static void main(String[] args) throws Exception {
CamelContext camelContext = new DefaultCamelContext();
camelContext.addRoutes( new RouteBuilder() {
@Override
public void configure() throws Exception {
浏览 2提问于2017-09-14得票数 0
回答已采纳
因此，我试图让一个MQXAQueueConnectionFactory工作，我已经从JmsComponent创建了一个扩展类，以便在向队列发送数据时处理用户名和密码。它确实在队列中获取/放置消息，但在我的示例中，我创建了一个路由器来测试XA，如
from("wmq:queue:incomingQueue")
.process(new Processor(){
... Thread.sleep(20000)
})
.to("wmq:queue:outgoingQueue")
在睡觉的时候，我关掉了排队员。但是，当试图从队列
浏览 13提问于2015-03-25得票数 5
回答已采纳
追踪：
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
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
