ActiveMQ的骆驼：不能使用＆lt;到URI =＆QUOT; HTTP：//..."＆GT;
我需要帮助解决这个问题，下面code为bean.xml给我误差 ＆LT; camelContext ID =“activeContext1”的xmlns =“http://camel.apache.org/schema/spring”＆GT; ＆LT;＆路线GT; ＆LT;从URI =“的ActiveMQ：队列：ThermalMap”/＆GT; ＆LT;
..
activemq相关内容
控制骆驼航线的启动和关机
我试图让那种朝ActiveMQ的投票站服务的使用骆驼的路线队列。 我使用的路由和路由，JSM插件Grails的。 我有我的路由配置的设置是这样的。 类QueueRoute { 高清配置= { 从（“ActiveMQ的：守护程序”）。routeId（“daemonRoute”） .noAutoStartup（） .shutdownRunningTask（Shutdown
..
如何检测JMS主题连接丢失
我们有一个连接到一个服务器进程Swing GUI的客户。 客户的呼叫'使用 JMS服务器上的服务：队列'的'骆驼路线定义端点，并使用ActiveMQ的作为底层JMS代理 但是，客户端还提供了一个骆驼 JMS：题目终端服务器广播消息返回给客户端 不幸的是，它看起来像主题连接是越来越不知何故而丢失，虽然客户仍可以“呼叫”服务器上的服务，服务器无法发送任何信息到客户端的话题终结点。 骆驼端点的客
..
Apache的骆驼：回复收到未知的correlationID
有在其他的两个软件组件中间件。在中间件我被 Apache的骆驼的Apache ActiveMQ的信息C>。 这是它如何工作的： 中间件 1stComponent 用来发送邮件到 3rdComponent 3rdComponent 回复的消息，并将其返回到 1 （使用中间件）。 1stComponent＆LT;＆LT; = GT;＆GT;中间件＆LT;＆LT; = GT;＆GT;
..
从豆骆驼响应返回到ActiveMQ的队列
我用骆驼（与骆驼EJB依赖）从ActiveMQ的我bean的方法来路由消息。到目前为止，我已经得到了它在我的requestHandler豆收到消息。 ＆LT; AMQ：connectionFactory的ID =“amqConnectionFactory” brokerURL =“TCP：//本地主机：61616”/＆GT;＆LT; bean类=“org.springframewor
..
从DB消息允许骆驼重播机制
荫试图实现与骆驼即重播mechanisam，我将不得不检索所有消息已经坚持并转发到相应的骆驼路线reprocess.This将石英调度程序triggred。 我通过以下实现的相同。 1）一旦石英调度被触发，转送到处理器，将查询数据库，并有消息作为列表并设置在骆驼交换属性列表相同。 2）使用其中LoopProcessor将在交换迭代设置适当的XML骆驼。 3）它FWD到将被转发到相应的骆驼航
..
如何在骆驼航线使用XPath设置JMS消息自定义标题
我使用骆驼的路线生成器来设置一些自定义标题，通过使用XPath读取从XML节点值从一个队列移动一个ActiveMQ的JMS消息到另一个。什么也没有设置。如果您知道答案请建议。 从（“ActiveMQ的：com.queue1”） .setHeader（“订单号码”）。XPath的（“/ orderRequest / authNumber”） 。要（“
..
ActiveMQ的并发在Apache的骆驼航线失败
试图在同一时刻发送多个请求骆驼ActiveMQ的路线，一个请求服务，其他请求不提供服务，并发送回原样。该JMS消息太下方发送像以前那样设定JMScorrelationId textMessage.setJMSCorrelationID（UUID.randomUUID（）的toString（））; 下面是我的ActiveMQ路线从（“ActiveMQ的：队列：TEST_QUEUE disab
..
ExchangePattern.InOnly对MQ端点的影响
我有我的路线定义为from(\"jetty:http://0.0.0.0:xxxx/abc\").to(\"activemq:queue:queue1\").setExchangePattern(ExchangePattern.InOnly); 据我了解，这条路线滴meessage到代理并不会等待消息的消费者来使用它。我想了解ExchangePattern.InOnly相对于冲击经纪人接受的
..
Apache的骆驼 - JMS INONLY行为时，经纪人下来
我生产与骆驼的ActiveMQ组件的ActiveMQ的实例： ＆LT;骆驼：日志消息=“YMA_IN”/＆GT; ＆LT;骆驼：INONLY URI =“activemqBroker：队列：queue.test”ID =“activemqBrokerTestQueue”/＆GT; ＆LT;骆驼：日志消息=“YMA_OUT”/＆GT; 在端点上唯一的JMS配置为TTL和池连接工厂。＆LT; A
..
JSONPath前pression在Apache的骆驼XML字符串检查
让我们说我有一个简单的JSON文件，如以下 { “日志”：{ “主持人”：“嗒嗒” “严重程度”：“INFO”， “系统”：“1” } } 我使用Apache的骆驼，它是春天的XML处理和路由JSON文件。我的路由code看起来是这样的：＆LT;＆路线GT; ＆LT;从URI =“文件：/ TESTFOLDER /输入
..
如何读取基于消息头属性只有特定队列中的消息
我在ActiveMQ的队列中的邮件列表。每个消息有值自定义标题属性。我应该怎么只能访问其自定义页眉属性值这些消息= 123？ 我使用类似下面接从队列中的消息。如何挑选所有的消息或具有customHeaderProperty = 123？单个消息 ConsumerTemplate consumerTemplate = camelContext.createConsumerTemplate（）;
..
在运行时创建JMS队列
我工作的一个应用程序，应用程序，用户可以创建/删除队列。此外，他将能够基于一些过滤器在队列1队列中移动消息到另一个，删除邮件，重新安排的消息。 一个可能的设计是使用ActiveMQ的为队列和Apache骆驼其他各种操作使用Grails具有集成。 但我不知道的ActiveMQ是否允许创建/ deleltion队列在运行时。结果 这会是一个不错的选择来实现这样的系统？ 解决方案 是的，你
..
ActiveMQ的骆驼消息
我尝试部署使用的ActiveMQ和骆驼的应用程序，当我strating我的Tomcat服务器我正在控制台上的所有可疑邮件，即使有在塔伊经纪人的队列中没有消息，该错误消息。 09：56：27.769 [骆驼（eventProcessorCamelContext）线＃2 - JmsConsumer [赛事] DEBUG oaactivemq.ActiveMQMessageConsumer -
..
发送消息从HTTP端点JMS
我想有一个骆驼的路线，这将接受一个HTTP端点的有效载荷，然后写一个有效载荷到JMS队列。 这是我到目前为止的路线如下。但是一个空消息被传递到JMS队列。消息到达那里，但它没有身体。 继承人的路线： ＆LT;＆路线GT; ＆LT;从URI =“码头：HTTP：//0.0.0.0：8050 /添加/客户”/＆GT; ＆LT; INONLY URI =“JMS：队列：Q.Cust
..
从骆驼航线强制套接字超时上的ActiveMQ？
所以，下面我有骆驼（通过Spring DSL）成功整合我的豆子和ActiveMQ队列： ＆LT; - ！注：此code只是一个片断;如果您需要查看更多，请让我知道！ - ＆GT; ＆LT; camelContext ID =“我的骆驼上下文”的xmlns =“http://camel.apache.org/schema/spring”＆GT; ＆LT;＆路线GT;
..
骆驼 - 内容富集器：充实（）VS pollEnrich（）
1ST问题： 我不能够真正理解之间的差异充实（）和 pollEnrich（）。也许条款骆驼的用途是没有那么大。 我读到这里： http://camel.apache.org/content-enricher.html 使用DSL富集元素含量富集 骆驼自带的DSL内容富集器的两种口味 充实 pollEnrich 富集使用制片以获得附加数据。它通常是 用于请求回复消息，
..
Apache的骆驼/ ActiveMQ的优先级路由
我有具有相同的消费者2 AMQ队列。 第一队列（Q 1）处理的消息的97％，而另一个（Q2）只有3％。 问题是，在Q2的消息需要，尽快为他们进行排队处理消息。 所以我的问题是，当一个消息在第二季度上市，我需要以某种方式暂停第一条路线把它的消费者。 Apache的骆驼路由看起来是这样的： ＆LT;路线ID =“Q1”＆GT; ＆LT;从URI =“JMS：recordAnalysi
..
骆驼动态路由无限EN-消息队列
结果 我的工作骆驼的动态路由器派生并派遣相关的队列通过参考的http：//骆驼。 apache.org/dynamic-router.html 结果 以下是骆驼配置XML： ＆LT;路线ID =“dynamicRouter”的自动启动=“真”＆GT; ＆LT;从URI =“VM：//服务1 concurrentConsumers = 10＆放大器;放大器;超时= 0”/＆GT;
..
与ActiveMQ的并行处理多个消息
我想并行处理使用一个简单的处理器/ AsyncProcessor为目的地的队列中的消息。处理器采用每个消息一点时间，但是每个消息可以单独同时进行处理，因此，（健康的界限内）。 我有一个很难找到的例子，尤其是关于骆驼航线的xml配置。 到目前为止，我已经定义了一个线程池，路线和处理器： ＆LT;线程池ID =“smallPool”threadName =“MyProcessorThread”p
..