我在MyRouteBuilder.java文件中有一个camel路由,它正在消耗来自ActiveMQ的消息:
from("activemq:queue:myQueue" )
.process(consumeDroppedMessage)
.log(">>> I am here");
我为下面的示例编写了一个测试用例:
@Override
public RouteBuilder createRouteBuilder() throws Exception {
return new MyRouteBuilder();
}
@Test
voi
在通过JMS连接到ActiveMQ Artemis时,基于Apache的应用程序中,我遇到了一个问题。在Camel路由的末尾,消息存储在Artemis队列中。运行在同一应用程序中的遗留组件定期使用ConsumerTemplate从其中提取它们。
这对于带有纯文本体的Camel消息很好,但在使用字节数组主体时会导致错误:似乎Artemis将任何带有字节体的消息作为来处理。通过ConsumerTemplate接收可以工作,但是一旦访问了主体或头,就会引发如下异常:
org.apache.camel.RuntimeCamelException: Failed to extract body due
在春季使用DefaultJmsListenerContainerFactory和camel使用故障转移activemq传输订阅消息时,我不断地收到以下信息消息。
2016-08-25 15:00:07,235 [ActiveMQ Task-1] INFO transport.failover.FailoverTransport Successfully connected to tcp://localhost:61616
2016-08-25 15:00:08,265 [ActiveMQ Task-1] INFO transport.failover.FailoverTransport Su
首先:我是Apache Camel和Stack Overflow的新手!
我已经创建了一条从SFTP服务器过滤和下载文件并在处理后删除这些文件的路由。
我的问题:在我的本地计算机上,路由工作得很好。当我在生产服务器上部署这个路由(相同的.war)时,下载可以正常工作,但是当FTP组件试图删除文件时,我得到下面的异常。开发和生产的机器有相同的camel,tomcat和java版本。唯一的区别是操作系统(开发人员: Windows 7,产品: Windows Server2008 R2)
有什么想法吗?
java.lang.IllegalArgumentException: Resolving l