apache-camel相关内容
我使用的是骆驼,SFTP组件文件上传到SFTP服务器。 在code是简单的: 文件源=新的文件(路径); 最后弦乐sftpUri =“SFTP://”+用户id +“@”+ serverAddress +“/”+ remote目录+“?密码=”+ PWD; CamelContext语境=新DefaultCamelContext(); context.addRoutes(新RouteBuilde
..
我想一个事件通知器添加到使用主类从骆驼我的Apache的骆驼独立的应用程序。 的http://camel.apache.org/running-camel-standalone-and-have-it-keep-running.html 公共无效启动()抛出异常{ 主力主攻=新的Main(); main.addRouteBuilder(新MyRouteBuilder());
..
我使用的是默认关闭的策略在我camelcontext。该路线开始与从队列中消耗超过10k的消息的RabbitMQ消费者。当我停止的路线,消费者不断从队列消耗新的消息。因此,空中交换计数从未递减和路线等待关机,直到默认的超时值(300秒)。有什么办法改变这种行为?基本上停止从消费新邮件时,正在关机的RabbitMQ的消费。 解决方案 我有同样的跟你的问题。问题的关键是关闭的时候,骆驼preF
..
我使用骆驼的路线生成器来设置一些自定义标题,通过使用XPath读取从XML节点值从一个队列移动一个ActiveMQ的JMS消息到另一个。什么也没有设置。如果您知道答案请建议。 从(“ActiveMQ的:com.queue1”) .setHeader(“订单号码”)。XPath的(“/ orderRequest / authNumber”) 。要(“
..
请参阅此
..
是否有可能使用骆驼流组件读取POST的输出到一个URL?喜欢的东西:<到URI =“流:URL URL = HTTP://本地主机:8080 / mycontext / myservlet”/> 我试过,但没有奏效。我需要张贴JSON对象到一个URL和处理返回一个巨大的有效载荷,所以我需要它被传输到一个文件,而无需首先加载它全部在内存中。是否有骆驼DSL的替代品或者我应该以某种方式使
..
试图在同一时刻发送多个请求骆驼ActiveMQ的路线,一个请求服务,其他请求不提供服务,并发送回原样。该JMS消息太下方发送像以前那样设定JMScorrelationId textMessage.setJMSCorrelationID(UUID.randomUUID()的toString()); 下面是我的ActiveMQ路线从(“ActiveMQ的:队列:TEST_QUEUE disab
..
我在项目中的骆驼背景: < camelContext ID =“camelContext”> <路线ID =“camelRoute1”> <从URI =“VM:富”/> <日志消息=“camelRoute1完成”/> < /路由> < / camelContext> 项目B
..
我读
..
我想呼吁的HTTPS URL,在需要的客户端认证方式(SSL)一个SOAP Web服务。 现在我用配置我的春天般地上下文(切换从蓝图的距离)和创建使用骆驼CXF组件与码头运输我的终点。 我找不到这方面的任何很好的例子在那里。也许我应该在码头的使用代替http4。我试图建立一些骆驼sslContextParameters,但我不能看到CXF和/或Jetty这方面的工作。 任何人都可以点我在正确
..
我写一个连接到IBM MQ队列管理器的客户端模式样本Apache的骆驼(2.16.2)应用程序。 Apache的骆驼使用Spring JMS下方连接到JMS提供者。我看到Spring JmsAccessor 不具有的createConnection ()方法,它的用户ID和密码。它只有一个不带任何参数的createConnection ()方法。由于此创建连接到队列管理器的失败,2035 -
..
我有一个分流器的路线。我需要在每次发生什么时间停止分裂作业。当然onCompletion可以帮我,但是: 关于帖子“
..
我有一个骆驼路线用Java编写的DSL这样的定义: 从(myEndpoint) .throttle(200) 。要(myOtherEndpoint); 本使用这限制了消息流,以每秒200消息的节流连接我的两个端点。 我在寻找一种方式在运行时改变maximumRequestCount /秒。 所以,我需要以某种方式获得的节流实例,被调用,改变属性。 我如何访问节流? 解决方案 好吧,我想通
..
我们有在其上的系统中发生的事件的发布的ActiveMQ。该项目涉及的用户添加实体他们的观察名单,每当有这些实体的事件,我想的电子邮件被发送到感兴趣的与会者。 用例大致翻译对某一前pressing在目录和电子邮件中的产品信息页面的兴趣被发送,只要任何活动发生在该产品(价格下跌,有一个积极的评价等。,)。我曾仿照这种互动为骆驼的路线。 因此,举例来说,如果用户说,每当这个产品的评级等于5发邮件
..
我想骆驼与WebSphere集成。它工作正常,为所有,但一件事。 场景是这样的: JMS(WMQ) - >路由/转换 - > BEAN(它做了JPA(OpenJPA1.2 / DB2)提交) 要能够插入到WAS事务管理器和mangaed线程,我插入工作管理器作为了taskExecutor骆驼: <! - Spring配置选件 - > < TX:JTA事务经理/>&
..
我怎样才能将消息发送到端点,而无需等待该终端是路线的过程(也就是我的路线应该只是分派消息,并完成)? 解决方案 窃听(终点)就是答案。
..
我需要发送两个不同的XML的(被FreeMarker)两个不同的端点。 即。 。要(“FreeMarker的:模板/ xml1.ftl”)。为了(“文件:// C:\\\\ testXmls1”) 和。要(“FreeMarker的:模板/ xml2.ftl”)。为了(“文件:// C:\\\\ testXmls2”) 我有一个看组播()功能,但我不知道如何使用它的时候有两个。要 谁能帮
..
一个客户使用此模式: Apache的骆驼和CXF JMS接收器 这些内部使用Spring的MDP(消息驱动的POJO)来实现他们的信息接收器 它们部署在IBM WebSphere Application Server上7 的队列管理器的IBM WebSphere MQ 6 春季的MDP绑定到使用JNDI队列连接工厂队列管理器 - 为连接池和会话支持池 下面是这种消息接收机的
..
我有我的路线定义为from(\"jetty:http://0.0.0.0:xxxx/abc\").to(\"activemq:queue:queue1\").setExchangePattern(ExchangePattern.InOnly); 据我了解,这条路线滴meessage到代理并不会等待消息的消费者来使用它。我想了解ExchangePattern.InOnly相对于冲击经纪人接受的
..
问题可能与我的概念的理解了。 ActionClass 正在调用代理bean是 AccountingInterface 。代理bean接口与 AccountingUtil 类实现。所以我期待 XML 按 AccountingUtil 返回到 SEDA传递:accountingQueue ,然后流出来控制台。 的ApplicationContext <豆的id =“accounti
..