在下面的路由中,我期望来自queue1的10 msg应该同时进行处理,但是一次只有一个进程. 我错了吗？或做错了什么？ context.addRoutes(new RouteBuilder() { public void configure() { from("test-jms:queue:test.queue1").t
在驼峰中,说并非所有ENDPOINT都支持INOUT ExchangePattern是否正确？ 如果是,那么文档的哪一部分告诉哪个端点支持哪个ExchangePattern或者这是隐式的知识. 它最多为ENDPOINT提供对INOUT的支持. 下面是我得出结论的代码示例. 我正在玩camel example-jms-file并将其修改为 queue1 –
我是Netty的新手. 我正在寻找一些样品. (优选但不是必须使用Camel Netty Component和Spring) 特别是一个使用TCP消息的示例Netty应用程序. 另外,我如何编写可以测试这个netty应用程序的JUnit测试？ 谢谢, 达累斯萨拉姆解决方法:我假设您仍想与Camel集成.我先来看看camel documentatio
我定义了10条路线,其中2条列在此处.其他8个是相同的,但是从端点是不同的目录.每个路由选取一个位于目录中的文件,并由一个groovy类处理.当一个文件被放入其中一个目录时,它工作正常,但是当一个文件同时被丢弃到每个目录中时,每个线程似乎都会变得混乱.我确实收到了我已经获取每个文
我们开发了一个Camel软件包(部署在Karaf中),预计每24小时从MySQL提取数据并将其推送到S3.但是,如果MySQL在8小时内空闲,内部关闭连接,因此在下一次计划执行时,它会开始抛出错误.请参阅我们的代码中的以下片段. 属性： MySqlDriver=com.mysql.jdbc.Driver MySqlDatabaseURL=jdbc:mysq
我有一个休息服务,它将消息发送到我的队列,并将这些消息路由到文件： from("test-jms:queue:test.queue").to("file://test"); 此外,我在端点上有一个事件驱动的消费者.现在,只有在消息消耗时才会写入日志： final Consumer consumer = endpoint.createConsumer(new Processor() {
我有一个非常简单的骆驼路线.它以作为Web服务公开的CXF端点开始. 然后我想将它转换为xml并在bean上调用一个方法. 目前我正在获取Web服务调用后的CXF特定对象.如何将序列化对象从CXF MessageList中取出并继续使用？ 我的路线： <camel:route> <camel:from uri="cxf:bean:helloEndpo
我有Camel路由,我想作为REST Web服务公开.应用程序部署在Web容器(Jetty / Tomcat)上,Spring也用于DI和其他“基础结构”事物. 我看了camel-restlet和camel-cxfrs组件,虽然它们都支持将路由暴露为REST服务但我无法找到如何避免启动单独的服务器.我真正想要的是能够以类似于如何为Spr
我现在讨厌了一段时间,但由于很多配置文件都在xml中,所以很难找到我的问题的一些答案. 我想做什么？ 使用caml路由我想读取xml文件并将其放入POJO.在这里,我想分析一下.最后,我想写一个不同的xml文件(POJO)作为out文件夹的答案. 我的问题是,我不知道如何告诉camel将xml文件体解析为我
我正在尝试使用log4j将交换体记录为字符串. <convertBodyTo id="_convertBodyTo1" type="java.lang.String"/> <to id="_to1" uri="log:com.javarticles?level=INFO"/> 但它不是以字符串形式记录的 15:09:05,403 | INFO | qtp938841692-57 | javar
我们在Web应用程序中使用Spring和Camel.在我们的一个控制器中,我们使用ProducerTemplate在路由上发送消息,现在我想添加另一个控制器,它将在单独的路由上发送消息.我试图了解我们是否只想为整个应用程序安装一个ProducerTemplate？ 我问这个是因为我在读完this之后有点困惑.解决方法:
我有一个问题,并且不知道如何使用驼峰来解决它.我在骆驼文档中搜索了相关的EIP,但没有结果. 现在我有简单的路线： <route id="routeId"> <from uri="Source1"/> <from uri="Source2"/> <to uri="Destination"/> </route> 两个源都将JMS消息发送到
我创建了一个proxy-camel,它接受SOAP(通过HTTP)和RESTful请求,并将它们转发到正确的Web服务. Camel不知道消息结构,它不知道WSDL或任何东西,它根据http头只知道它是否是SOAP.没有CXF端点. 此外,它做了一些处理.例外情况可能发生在那里,例如,当找不到服务或网址无效时.有没有一种简
让我们举例说,我有以下路线： from(.....) .choice() .when(condition1) .bean(Class1.class,"method1") .when(condition2) .bean(Class1.class,"method2") .otherwise() .bean(C
我在camel中遇到问题,在运行时从XML加载路由. 我搜索了我的问题,并在http://grokbase.com/p/camel/users/117w8m6rbm/injecting-data-to-routes-loaded-from-xml-file.找到了相关的讨论 我的问题有点不同.我想运行下面给出的那条路线. <routes xmlns="http://camel.apache.org/sch
我目前正在利用Apache Camel(编写本文时的版本2.20.2)作为更大的ETL流程的一部分,将处理过的文件从Camel盒复制到另一台机器. 但是,我有一段时间处理SCP配置.其目的是使其不必在私钥所在的位置以及已知主机所在的位置之外提供更多内容. 以下是示例路线.样本路由仅用于交谈;它可能不
我有一个Java项目,它当前将一个映射返回给Camel而没有任何嵌套的键,值对,并且Jackson库使用Jackson库将它编组到JSON中. 例如,如果我将以下两个键值放入demoMap中： Map<String,String> demoMap = new TreeMap<String,String> demoMap.put("key1","5"); demoMap.put("key2","10")
