追踪:
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
我想用Camel发送一条消息到JMS队列中。主体是字节数组,我希望Camel将其转换为javax.jms.BytesMessage并发送它,没有问题,但我得到以下警告。
Warning
[org.apache.camel.component.jms.JmsBinding] (Camel (camel) thread #0 -
JmsConsumer[devrechTransactionsQueue@z4smq_4001)
Cannot determine specific JmsMessage type to use from body class.
Will use generic Jm
我正在尝试将Camel与WebSphere集成。它工作得很好,除了一件事。
该场景类似于: JMS (WMQ) ->路由/转换DB2Bean(它执行-> (OpenJPA1.2/DB2)提交)。
为了能够插入WAS事务管理器和人工线程,我将工作管理器作为taskExecutor插入到camel中:
<!-- Selected parts of the spring config -->
<tx:jta-transaction-manager/>
<bean id="wasTaskExecutor"
class="org
我想通过骆驼路由发送PDF到ActiveMQ队列。我需要在另一条骆驼路线上提取这些PDF。我无法从队列中提取数据。我也和.marshal().base64()试过了。数据到达Message,但我无法提取它。
将出现以下错误:
org.apache.camel.component.jms.JmsConfiguration.chooseMessageListenerContainerImplementation(JmsConfiguration.java:466) at org.apache.camel.component.jms.JmsConfiguration.createMessageLi
我得到了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}
我正在尝试将WebLogic12.1.3中的JMS队列与camel-jms结合使用。当我试图在队列中保存一些东西时,我得到了错误:
Caused By: weblogic.jms.common.JMSException: [JMSExceptions:045102]A destination named "jms/TestJMSQueue" was not found on WebLogic Server instance "AdminServer".
为了在服务器上配置jms队列,我遵循了以下教程:
我的camel配置:
<beans>
&
以前部署在JBoss EAP 6+JDK1.8+ Camel 2.18.4上的Java 8项目会发生以下运行时错误:
java.lang.LinkageError: loader constraint violation: when resolving field "log" of type org.slf4j.Logger, the class loader 'deployment.XXX.war' @1b683b29 of the current class, org.apache.camel.component.sql.SqlProducer, and t
在我的骆驼Router.java,我有下一个路线
from("jms:topic:test.source.topic?asyncConsumer=true")
.log("Message: ${body}")
.to("kafka:testing?brokers=192.168.0.100:9092");
from("kafka:testing?brokers=192.168.0.100:9092")
.log("Message received f
在3台运行Zookeeper + ActiveMQ的虚拟机上。ActiveMQ版本5.15.9与驼峰版本2.19.5 现在,我在ActiveMQ中使用嵌入式Camel EIP Framework。我想根据事件从Zookeeper获取一个特定的节点。 <camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
<!-- You can use Spring XML syntax to define the routes here using t
在我的camel RouteConfig.java中,我无法连接到mongo数据库。我得到以下异常:原因: org.apache.camel.NoSuchBeanException:在注册表中找不到类型为: myDb的bean : com.mongodb.Mongo at org.apache.camel.util.CamelContextHelper.mandatoryLookup(CamelContextHelper.java:130) at org.apache.camel.component.mongodb.MongoDbComponent.createEndpoint(MongoDb