在JMS主题上进行Apache Camel多播，然后聚合响应
是一种消息传递模式，用于在分布式系统中进行消息广播和聚合响应。下面是对这个问题的完善且全面的答案：
- 概念： JMS主题（Java Message Service Topic）是一种发布-订阅模式的消息传递机制，用于在分布式系统中进行消息的广播。 Apache Camel是一个开源的集成框架，用于在不同的系统之间进行消息传递和转换。
- 分类： 在JMS主题上进行Apache Camel多播，然后聚合响应属于消息传递和集成领域。
- 优势：
- 灵活性：通过使用Apache Camel，可以轻松地将不同的系统集成在一起，实现消息的传递和转换。
- 可靠性：JMS主题提供了可靠的消息传递机制，确保消息能够被正确地广播到所有订阅者。
- 扩展性：通过使用多播和聚合响应的方式，可以将系统扩展为支持更多的订阅者和处理逻辑。
- 应用场景：
在以下场景中，可以使用在JMS主题上进行Apache Camel多播，然后聚合响应：
- 实时数据分发：将实时数据广播给多个订阅者，例如股票市场的实时行情数据。
- 事件通知：将系统中发生的事件通知给多个订阅者，例如系统故障通知。
- 数据聚合：将多个系统的数据聚合到一个中心系统中，例如日志收集和分析。
- 推荐的腾讯云相关产品和产品介绍链接地址：
- 腾讯云消息队列 CMQ：https://cloud.tencent.com/product/cmq
- 腾讯云云函数 SCF：https://cloud.tencent.com/product/scf
- 腾讯云消息队列 CKafka：https://cloud.tencent.com/product/ckafka
以上是对在JMS主题上进行Apache Camel多播，然后聚合响应的完善且全面的答案。
相关·内容
我遇到了一个具有挑战性的情况，我试图在一个ActiveMQ代理上执行一个分散聚集的企业信息门户模式。在我的设计中，我决定使用。我想做的路线是这样的：
ActiveMQ:Queue:Test -> Multicast -> ActiveMQ:Topic:Vendors -> Aggregate (Responses received from ActiveMQ:Topic:Vendors) -> ActiveMQ:Queue:Test
本质上，我希望能够发送一个请求XML消息到ActiveMQ队列“测试”，请求消息被多播到订阅了主题“供应商”的所有供应商，然后收集所有响应
浏览 15提问于2018-02-08得票数 0
我正在将现有代码从使用ActiveMQ 5.x迁移到使用Artemis。使用org.apache.activemq.ActiveMQConnectionFactory时，我的虚拟主题使用者队列中有消息发送给排队的虚拟主题。当使用org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory时，它们不会。
使用ActiveMQ 5.x的连接工厂为虚拟主题工作的连接池配置是：
<bean id="jmsFactory" class="org.apache.activemq.jms.pool.Pooled
浏览 3提问于2021-04-20得票数 0
回答已采纳
我得到了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}
浏览 1提问于2020-11-03得票数 10
我正在运行一个带有所有地址(match="#")的Artemis 2.18
<auto-create-queues>true</auto-create-queues>
<auto-create-addresses>true</auto-create-addresses>
当我开始使用Camel JMS组件从不存在的多播队列中消费时
from("jms:topic:my_topic")
在my_topic地址下生成的队列名是神秘的: 5ae02282-6685-4558-bde4-6bf3dd61c146
浏览 7提问于2022-06-24得票数 0
如果我们必须向多个端点发送消息，则在Camel中有一个多播EIP。如果端点只是JMS端点呢？在这种情况下，我觉得这个话题比多播EIP更好。或者，如果端点是JMS端点，那么是否存在区分这两种方法的特定行为差异或模式？请澄清，谢谢提前！
浏览 2提问于2017-07-29得票数 0
回答已采纳
1回答
我目前正在使用ServiceMix使用QPID库路由消息。
我的工作配置如下：
<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="
http://www.osgi.org/xml
浏览 5提问于2018-05-28得票数 0
回答已采纳
下载Artemis2.13.0，预先创建一个多播地址测试，然后在这个地址上创建一个多播队列123，使用控制台向123队列发送1条消息
使用IDEA创建一个springboot项目，pom文件导入以下依赖项
org.springframework.boot spring-启动器-artemis org.springframework spring-jms 5.2.5. compile编译org.apache.activemq artemis-jms-client 2.13.0编译
pplication.properties添加配置
spring.artemis.mod
浏览 0提问于2020-06-06得票数 2
我的问题似乎很简单，但我还没有找到解决它的方法……
我有一个正在运行的遗留系统和一个将取代它的新系统。这只是rest webservices调用，所以我在http服务上使用简单的网桥端点。
为了确保等功能运行，我想将它们放在两个系统的camel路由调度消息后面，但只返回遗留系统的响应，并记录两个系统的响应，以确保以相同的方式运行……
我创建了这个路由：
from("servlet:proxy?matchOnUriPrefix=true")
.streamCaching()
.setHeader("CamelHttpMethod
浏览 3提问于2017-05-11得票数 1
1回答
带休息路线的骆驼聚集
、、、
我有一个Camel应用程序，我试图根据来自不同响应(REST服务)的一些输出进行一些聚合。
这就是我到目前为止(骆驼路线)的情况：
@Component
public final class AggregationRoute extends RouteBuilder {
@Override
public void configure() throws Exception {
rest("/aggregation")
.get()
.to("direct:retrieve");
from("dire
浏览 2提问于2016-06-28得票数 1
2回答
Am 100%新进JMS和Camel
这就是情况
我有一个Spring应用程序，一个JMS (ActiveMQ)，Camel
web应用程序需要以异步方式通过camel向JSM发送信息。也就是说，在发送信息给骆驼之后，网站不应该等待回复。网页应继续。
而且，我的应用程序应该侦听队列中的任何响应。一旦接收到任何响应，就必须调用特定的bean。
这有可能吗？？
这是我客户端的配置
骆驼上下文:
<!-- START SNIPPET: e1 -->
<beans xmlns="http://www.springframework.org/schema/beans"
浏览 3提问于2013-01-22得票数 2
回答已采纳
在我的骆驼路由中，我使用队列中的消息；每条消息都包含标题"pad“(路径)和一个文件前缀。例如：
message1: pad="/some/dir"，file="AAA“message2: message2/message2/dir，file="BRD”
在每条消息中，我希望创建一个文件: message1: /some/dir/AAA.tar (包含所有文件/message2/dir/AAA*) message2: /another/dir/BRD.tar (包含/some/dir/brd.tar中的所有文件)
目录和文件名是在另一个路由中收集的。
到
浏览 1提问于2018-02-01得票数 0
回答已采纳
我在两台服务器上部署了Apache Camel应用程序，它们从JMS端点使用。我希望确保一次只有一条camel路由从jms端点消耗。我可以用于集群的唯一选项是使用数据库作为锁存储。Apache Camel提供这样的功能吗？
浏览 16提问于2021-06-26得票数 0
我一直在尝试让Camel Netty4 udp组播在windows上工作，而NettyUDPMulticastAsyncTest似乎在java.nio.channels.ClosedChannelException上失败了。同样的测试似乎也在OSX上进行。这两台机器都在运行Java1.7，我已经在测试中更新了接口名，并且能够在同一个接口上运行一个NIO多播示例。我正在使用Camel 2.14.1，但它似乎也不适用于2.15.x。
堆栈跟踪在下面。
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.026 sec
浏览 4提问于2015-06-29得票数 0
回答已采纳
我有一个使用来自JMS主题的消息的驼峰路由。当路由启动时，主题中没有消息，我想引发一个异常并停止该进程。
我使用的是Apache Camel的JmsComponent，它使用Spring的DefaultMessageListenerContainer，并且被定义为事务性的。当前的行为是路由启动，但它会无限期地等待消息。
有没有什么办法可以检查消息是否存在，如果消息不存在，就简单地停止路由？
浏览 1提问于2015-02-20得票数 0
2回答
我们有一个ActiveMQ / Camel配置，它以前一直只使用消息队列，具有并发使用者。
然而，我们现在引入了消息主题，并且发现-由于并发消费者-在主题中接收的消息被多次消费。
此场景的正确配置是什么？
也就是说，我们希望队列上收到的消息有多个并发消费者，但只需要为主题上收到的消息定义一个消费者。
下面是当前的配置：
<amq:connectionFactory id="amqConnectionFactory"
useAsyncSend="true" brokerURL="${${ptl.Servername}.jms.cluster.
浏览 2提问于2012-03-27得票数 2
回答已采纳
1回答
我试图将X?-GB大文件作为流发送到ActiveMQ队列进行处理。
我知道ActiveMQ ，也知道，但是我试图在队列中设置的任何东西似乎都没有什么区别。唯一的改变是关闭流缓存结果，而不是一个“流关闭”异常。
我愿意使用处理器或自定义类(只要清理了资源)，但从蓝图来看，这是可能的。如何在没有获得OutOfMemoryError的情况下通过camel-activemq正确地处理大型文件？
使用
servicemix-7.0.0
camel-2.16.4
activemq-5.14.3
这是我的骆驼蓝图
<?xml version="1.0" encodi
浏览 4提问于2017-10-17得票数 7
回答已采纳
2回答
我正在编写一个应用程序，使用Akka，Akka-Camel和Spring进行配置.应用程序需要针对各种应用服务器充当独立的JMS客户机，为此需要使用JNDI设置JMS连接工厂。我正在用jBoss测试这个。jBoss 5和6也有同样的问题(这似乎是一个客户端Spring问题，与jBoss无关)。
我正在使用以下xml配置Spring：
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instanc
浏览 0提问于2013-06-04得票数 3
1回答
我试图使用AMQP队列作为路由的开始和结束。我很难让它正常工作，就像的例子
谁能帮我指出正确的方向吗？
我把它部署在一个空手道的蓝图容器中。
我的设计是：
<bean id="amqpConnectionFactory"
class="org.apache.qpid.amqp_1_0.jms.impl.ConnectionFactoryImpl"
factory-method="createFromURL">
<argument value="${IssBroker.url}&
浏览 3提问于2015-10-09得票数 0
回答已采纳
我对Camel和JMS有问题。
我的路线非常简单：
@Override
protected RouteBuilder[] createRouteBuilders() throws Exception {
createJmsComponent();
RouteBuilder route1 = new RouteBuilder() {
@Override
public void configure() throws Exception {
from("direct:
浏览 0提问于2012-07-04得票数 2
回答已采纳
1回答
我正在尝试创建持久的端点。我使用solace-jms-spring-boot-starter。
我如何尝试：
amqp:topic:testTopic?clientId=1&durableSubscriptionName=Test&subscriptionDurable=true
OR
@Autowired
private JmsTemplate jmsTemplate;
final ConnectionFactory connectionFactory1 = jmsTemplate.getConnectionFactory();
final Connection conn
浏览 71提问于2018-12-13得票数 0
回答已采纳
我正在努力寻找最快的方式使用骆驼将消息从一个ActiveMQ Artemis队列传输到另一个。我认为Camel的组件比Camel的传统组件更快，但是使用JMS的路由要快2.5倍(20,000 vs 8,000 msg/s)。我使用Camel版本2.20.2和Artemis版本2.11.0。
带JMS的路由
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.imp
浏览 3提问于2020-02-26得票数 1
回答已采纳
我试图在Apache中使用多播企业集成模式(EIP)，但是遇到了很多运行时异常。我认为主要的错误在下面。如果有人能帮我解决这个问题，我想我可以让这个小程序运行起来。请参阅下面的错误和程序。
错误：Caused by: org.apache.camel.InvalidPayloadException: No body available of type: java.io.InputStream but has value: 100 of type: java.lang.Integer on: Message: 100. Caused by: No type converter available
浏览 3提问于2016-05-01得票数 2
回答已采纳
例如，我使用Camel 2.14.1将消息路由到一组端点：
from(...)
...
.to(monitoringEndpointId, broadcastEndpointId);
我想在运行时动态地启用/禁用这些端点/路由。到目前为止，我已经尝试使用的stopRoute和suspendRoute方法，例如：
camel.suspendRoute(broadcastEndpointId)
但这会导致以下例外情况：
An unknown exception occurred:
org.apache.camel.component.direct.DirectConsumerNotAvailabl
浏览 3提问于2016-04-14得票数 3
回答已采纳
我在spring boot应用程序中使用Apache Camel和ActiveMQ。有时它会抛出一个错误，说明会话已关闭。我必须重新启动应用程序以消除此错误。 我已经阅读了一些文章，这些文章表明应用程序正在耗尽最大会话限制(默认为500)。下次发生此错误时，我将查看activemq面板，以查看与连接对应的活动会话。 下面是我的配置文件： <camelContext id="camelContext" xmlns="http://camel.apache.org/schema/spring">
<contextScan/>
浏览 115提问于2019-04-22得票数 1
1回答
骆驼多播；Direct
、、、、
我有一个通用的Camel路由，它使用DataFormat: POJO侦听CXF:Bean(SOAP)请求。
我想要做的是将传入的交换多播到AMQ队列，该队列将由另一个内部路由在以后的某个点使用，而另一个端点是一个直接的:端点，它将被使用SOAP消息来响应，例如，“成功”
但是，我在StackTrace中得到了以下错误：
015-06-03 16:56:49.645 INFO 4992 --- [qtp110495750-79] XxToYyyAsynchronizerRoute : An error has occurred. java.lang.Runtime
浏览 2提问于2015-06-03得票数 0
回答已采纳
我正在努力创造一条骆驼路线，它将：
从队列中获取JMS消息，消息体是SOAP请求。
将消息发送到cxf端点。
将响应放入响应队列。
这是我的密码：
private void setupRequestRoute() {
from("jms:queue:input")
.setHeader(CxfConstants.OPERATION_NAME, simple("XXXXXX"))
.setHeader(CxfConstants.OPERATION_NAMESPACE, simple("XXXXXX")
浏览 0提问于2018-12-03得票数 1
回答已采纳
我有一个“骆驼蓝图”的定义，其中包含两个骆驼上下文，每条都包含一条路线。
首先调用上下文路由，然后调用第二个上下文的路由。现在，如果在第二条路由中抛出异常，而onException设置handled=true，则在第一条路由doFinally块中，只调用第一个处理器。
以下是我的蓝图定义：
<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
xmlns:xsi=
浏览 1提问于2013-12-05得票数 1
回答已采纳
我有一个groovy脚本，我正在尝试使用它；它的工作是读取一个消息队列，然后将这些消息重新排队到一组新的MQs中。
代码如下：
@Grab(group='org.apache.camel', module='camel-core', version='2.11.0')
@Grab(group='org.apache.activemq', module='activemq-core', version='5.7.0')
@Grab(group='org.apache.activemq'
浏览 1提问于2013-06-05得票数 3
当我在一个AMQ Artemis队列中收到一个大消息(100KiB+)，并试图将这个消息路由到另一个AMQ，并且这个消息具有_AMQ_LARGE_SIZE属性时，我得到了以下错误： 14:38:56.250 [Camel (CamelTestRoute) thread #1 - JmsConsumer[QUEUE.TEST]] WARN o.a.c.c.jms.EndpointMessageListener - Execution of JMS message listener failed. Caused by: [org.apache.camel.RuntimeCamelExcepti
浏览 28提问于2019-06-06得票数 0
回答已采纳
因此，我有一个从一个队列中使用JMS消息的路由，我希望将它发送到同一个代理上的另一个队列。蓝图xml非常简单：
<camel:route id="from-jms-consumer-to-jms" trace="false">
<from uri="jms:queue:test" />
<log message="Message consumed :: ${body}" />
<to uri="jms:queue:other_tes
浏览 0提问于2019-08-15得票数 0
我已经绝望了。 我在这个url上找到的文档一定很愚蠢： https://access.redhat.com/documentation/en-us/red_hat_fuse/7.0/html/deploying_into_apache_karaf/deployjmsbroker Fuse 7.0没有附带默认的内部代理，但它被设计为与外部JMS代理进行交互。 在完成所有的教程之后，我得到了这个错误： Message History
----------------------------------------------------------------------------------
浏览 37提问于2019-09-03得票数 2
回答已采纳
3回答
我需要增强分布式java应用程序的JMX接口。选择JMX的原因是公开数据的简单性。这些分布式应用程序存在于连接到JMS服务器(activemq5.7)的几个不同的机器上(该服务器又连接到另一个JMS服务器，以桥接2个网络，也就是activemq5.7)。
我想要做的是，能够从JMS网络上的任何位置访问各个服务器上的远程JMX接口。我需要完全的JMX访问，就像通过通常的RMI接口访问一样。这意味着每种类型的动作。
我知道我可以使用来使远程jmx接口与JMS服务器通信，并且我的网桥应该允许我从那里访问它们(假设它配置正确)。
这是一种好的方法吗？有没有人为了这个目的尝试过lingo？有没有其他我可
浏览 0提问于2012-12-19得票数 2
回答已采纳
1回答
我在Spring中配置了一个Apache路由，它接收来自JMS (ActiveMQ)队列的消息，转换消息并使用CXF组件将结果发送到web服务。这一切都很好，但我总是在路由的末尾抛出一个异常，说明CXF响应对象是不可同步的，因为它试图将exchange/message正文转换回JMS消息。但是为什么呢？
这是我的骆驼上下文摘录：-
<route>
<from uri="jms:queue:transactions" />
<process ref="convertToFormatForCXF" />
<to
浏览 0提问于2014-06-20得票数 1
回答已采纳
我有一个发布者正在发布关于主题的消息，我有2个订阅者S1 & S2正在接收这些消息。当我的发布者发送一条消息，并且两个订阅者都在运行时，他们都会收到该消息。但是，当我的订阅服务器没有启动，而我的发布者发送消息时，当订阅服务器出现时，它们就不会收到消息。我的订阅服务器如何接收未运行的消息？
注意:我正在使用Spring。
MessageProducer.java
@RestController
@RequestMapping("/rest/produce")
public class MessageProducer {
private static final L
浏览 0提问于2019-01-20得票数 0
回答已采纳
我正在生成一个带有驼峰ActiveMQ组件的ActiveMQ实例：
<camel:log message="YMA_IN" />
<camel:inOnly uri="activemqBroker:queue:queue.test" id="activemqBrokerTestQueue"/>
<camel:log message="YMA_OUT" />
端点上唯一的jms配置是TTL和一个池化连接工厂。
<amq:connectionFactory id="jmsConnect
浏览 2提问于2013-08-16得票数 1
我们有第三方应用程序对camel cxfrs端点进行restful调用，然后将其路由到外部activeMQ。有一些应用程序使用这些JMS消息并提供XML响应。这一切都是使用camel InOut exchangePattern同步完成的。这个架构非常简单明了。我们使用的是activeMQ 5.5.0-fuse、camel-jms 2.8.x和activemq pool 5.6。
使用此配置，我们可以在随机时间看到此异常：
javax.jms.InvalidDestinationException: Cannot publish to a deleted Destination: temp-
浏览 2提问于2013-04-23得票数 1
回答已采纳
我想用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
浏览 7提问于2011-08-16得票数 2
回答已采纳
这是的后续行动.
我的代码可以启动连接、会话等，但是消息不会被消耗。我在日志中没有看到任何例外。
此测试将复制问题：
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.naming.Context
浏览 9提问于2022-09-07得票数 0
回答已采纳
我已经将AMQ配置为从Oracle接收和发送消息，如所述
AMQ创建并保持连接以从Oracle AQ接收消息-这是正确的。但是，每次AMQ向Oracle AQ发送消息时，都会创建并销毁新连接。有时，由于一些网络问题或Oracle过载，我会得到一个异常：
org.apache.camel.RuntimeCamelException: org.springframework.jms.UncategorizedJmsException: Uncategorized exception occured during JMS processing; nested exception is oracle.
浏览 9提问于2018-03-26得票数 0
在通过JMS连接到ActiveMQ Artemis时，基于Apache的应用程序中，我遇到了一个问题。在Camel路由的末尾，消息存储在Artemis队列中。运行在同一应用程序中的遗留组件定期使用ConsumerTemplate从其中提取它们。
这对于带有纯文本体的Camel消息很好，但在使用字节数组主体时会导致错误:似乎Artemis将任何带有字节体的消息作为来处理。通过ConsumerTemplate接收可以工作，但是一旦访问了主体或头，就会引发如下异常：
org.apache.camel.RuntimeCamelException: Failed to extract body due
浏览 4提问于2020-01-08得票数 0
2回答
我是Camel的新手，不知道如何使用Camel实现下面提到的用例。
我们有一个REST web服务，假设它有两个服务操作callA和callB。现在，我们在前面有了ESB层，它在访问这个实际的web服务URL之前拦截客户端请求。
现在，我正在尝试这样做-在ESB中公开一个客户端将实际调用的URL。在ESB中，我们使用Camel的Jetty组件，它只代理这个服务调用。因此，假设此URL为/my-service/scan/
现在，在收到这个请求@ESB时，我想调用这两个REST端点(callA和callB)并获得它们的响应- resA和resB ->将其聚合为一个响应对象resScan -&
浏览 1提问于2012-05-16得票数 8
回答已采纳
多播().stopOnException()有什么作用？我写了一些路由： from("{{from.route}}").
multicast().stopOnException().to("jms:queue:carservice","jms:queue:flightservice");
from("jms:queue:carservice").throwException(new Exception("Car not working")).log("failed mes
浏览 14提问于2019-06-10得票数 0
下面是我和apache camel路由在Apache Service Mix 4.5.3中部署的内容。
<route>
<from uri="activemq:queue:EDI.CONTAINER.OUTBOUND.MESSAGES" />
<to uri="ftp://user@127.0.0.1:21/sin/file/in/?password=password"/>
<bean ref="processService" method="doProcess"
浏览 5提问于2014-03-12得票数 0
我在Camel DSL中使用组播，因为我需要将同一消息的副本发送到两个不同的端点。但是，这两个路由似乎相互干扰。我是不是搞错了语法，或者其他问题？
from("{{in.endpoint}}")
.routeId(this.getClass().getSimpleName())
.multicast().parallelProcessing()
.to("{{update.in}}", "{{add.ibmmq.topic}});
哪里
in.endpoint = seda:addOrder?waitForTaskToCo
浏览 2提问于2013-12-03得票数 1
我在空手道上安装了fcrepo-indexer-solr。并试图在fedora存储库中创建新的对象。然后，我在karaf日志中发现了以下错误。
此外，如果删除回购中的任何对象，则没有错误。只有当我创建或更新任何对象时，才会出现错误。我在这里错过了什么？请建议一下。
2016-04-04 14:15:47,696 | INFO | Consumer[fedora] | FcrepoSolrIndexer | 62 - org.apache.camel.camel-core - 2.16.2 | Index Routing Error: FcrepoSolrInde
浏览 5提问于2016-04-04得票数 1
回答已采纳
在我的骆驼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
浏览 1提问于2020-09-18得票数 1
回答已采纳
1回答
我应该使用AQjmsFactory.getConnectionFactory /Camel框架通过 API (如Oracle文档所述)连接到Oracle 单用户点对点队列。
下面的错误堆栈显示它试图创建一个主题连接。
有人能告诉我为什么吗？
非常感谢!
org.springframework.jms.UncategorizedJmsException: Uncategorized exception occurred during JMS processing; nested exception is oracle.jms.AQjmsException: JMS-243: Argomento
浏览 2提问于2017-12-04得票数 0
回答已采纳
我使用apache接收队列中的所有消息。但是我需要提到线程的睡眠时间来运行camel上下文。
现在的问题是它只消耗了一些信息。在指定的睡眠时间内。
如果我增加睡眠时间，那么它将路由所有的消息，但它要等到睡眠时间完成才能终止程序。
我需要的是，骆驼应该路由队列中的所有消息，然后它应该立即终止。
是否有任何方法可以在不指定线程睡眠时间的情况下使用java DSL来运行camel？
示例代码:
import javax.jms.ConnectionFactory;
import org.apache.activemq.ActiveMQConnection;
import o
浏览 3提问于2017-03-02得票数 0
回答已采纳
我们使用Camel2.15.4将Swing客户端连接到OSGi服务器。
在服务器中，在某些情况下，我们抛出一个想要传播回客户端的RuntimeException子类。
在构建我们的路由时，我们使用：
errorHandler(noErrorHandler());
但每次我们抛出这些服务器错误之一时，我们都会收到一条带有完整堆栈跟踪的警告日志消息。测试人员发现这些日志消息相当令人不安，因为它们看起来像是问题。
有没有办法关闭这些警告的日志记录？
下面是一个例子：
16:37:12,565 | WARN | che.camel.camel-core | Execution of JMS mess
浏览 8提问于2016-08-31得票数 0
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
