我正在监听来自activeMq embedded broker队列的消息(比如原始消息)。此消息首先移动到通道，然后传递到路由器，并根据传递到aggregator.Aggregator的条件等待另一条消息，然后将部分或聚合消息传递给服务激活器类。根据一些逻辑，激活器类决定抛出异常，我们期望消息再次重新传递，因为我们已经配置了ActiveMQ broker端重新传递插件。如果没有聚合器，如果达到最大重试次数，消息将被正
浏览 16提问于2016-08-25得票数 2
我们正在构建一个只与JMS (ActiveMQ)连接的分布式Java系统(应该是可伸缩的;-)。我学习了Spring集成，我不确定如果我们使用它会有什么好处。我认为我们最好使用Spring Core Project中的JMS-Templeate，因为我们只从一个JavaService向另一个JavaService发送消息，依此类推。
浏览 1提问于2011-09-07得票数 0
我们有一个包含2个聚合器、一些转换器、适配器等的Spring Integration上下文……此上下文使用来自ActiveMQ队列的消息，以及2个them服务，并将它们放入聚合器中。我们想要实现的是，每当我们在一个具体的队列中接收到一条消息时，我们将重置聚合器和每个statefull组件中的所有消息，以启动每个
浏览 6提问于2017-02-21得票数 1
回答已采纳
1回答
我想在integration spring概要文件不活动时使用spring bean初始化ActiveMQ代理。我只想在默认配置文件中启动代理。integration">
浏览 2提问于2016-01-18得票数 1
我有一个非常简单的MessageHandler类，多亏了Spring Boot，它在运行时只需要以下几行代码和配置： @Component solace.jms.host=smf://aaaaa.xx.yy.com:8000完整的pom</groupId>
<arti
浏览 3提问于2018-09-27得票数 1
回答已采纳
我正在使用ActiveMQ 5.15.14，并在代理上使用自定义的重传策略，在尝试向客户端重新传递一次之后，将坏消息传递给DLQ。当使用基于Spring的客户端时，当从Java代码中抛出异常时，此方法将正确工作。但是，如果Java客户端崩溃或突然终止，则代理中的重传计数会增加，但无论重发尝试的次数如何，消息都不会发送到DLQ。
浏览 3提问于2021-01-15得票数 0
回答已采纳
我们使用由ActiveMQ触发的 5.14.2.1，使用和Spring访问Tomcat (v4.3.28)。我正在尝试配置一个重新传递策略，以便当我们使用session.rollback()将消息返回到队列时，它遵循策略。}" 我尝试了一些基于各种和 的排列，但都没有成功。无论我尝试什么，它都使用默认的重传行
浏览 2提问于2021-05-19得票数 0
回答已采纳
2回答
我将spring-boot-starter-activemq与PoolFactory结合使用。一切都很好用，很容易通过application.yaml进行配置，但我无法找到正确的方法注入自定义的RedeliveryPolicy。所以问题是我该怎么做？
浏览 8提问于2017-07-28得票数 3
回答已采纳
我是Spring Integration的新手，我想知道Spring Integration中是否存在一个组件，它可以帮助我将2个渠道的结果结合起来。我知道答案是聚合器，但是我不希望消息合并到一个消息中，但当来自两个通道的消息到达时，它们应该流向下游组件。这是一种循环屏障的情况。
谢谢你，阿迪
浏览 2提问于2014-12-17得票数 0
war文件与ActiveMQ Artemis一起部署在Wildfly 11上。总体方法使用x集群应用服务器，并将分区作业划分为y分区，每个服务器都有y/x侦听器，因此负载在集群周围均匀分布。对于最初的集成工作，我只定义入站网关，Wildfly将抛出以下异常：这是一个，它在为5 JmsListeners定义<
浏览 2提问于2019-01-15得票数 0
1回答
Spring集成-生产者队列容量限制
我们使用带有MessageChannelPartitionHandler的远程分区来发送分区消息到队列(ActiveMQ)，以便对工作人员进行挑选和处理。作业有大量的数据需要处理，许多分区消息正在发布到队列，来自replyChannnel的响应聚合器由于消息超时而失败，因为所有消息都不能在给定的时间内处理。我们还试图通过使用队列容量<integration:queue ca
浏览 3提问于2021-06-08得票数 0
回答已采纳
目前，我有一个工作的spring集成项目，它将消息发送到ActiveMQ的队列的一个实例。在处理程序为JMSSendingMessageHandler.java的情况下，它使用serviceActivator作为端点。但是现在我想要向多个ActiveMQ实例发送消息，这些实例将在配置文件中进行配置。在spring Integration中，没有现成的解决方案可用。我的需求示意图如下
浏览 1提问于2017-03-03得票数 1
(ActiveMQMessage.java:740) ~[activemq-client-5.15.0.jar:5.15.0] at org.springframework.integration.jms.DefaultJmsHeaderMapper.fr
浏览 30提问于2022-04-06得票数 0
我有一个简单的camel路由，它获取一个条目列表，将它们拆分，将每个元素发送到mq节点进行处理，然后通过聚合器将它们连接在一起。on 2 more items所以，camel产生了2个聚合器，每个聚合器都在等待4个项目，但他们只得到了两个。，上面的工作很好，但是当我们部署到我们的测试服务
浏览 1提问于2014-08-22得票数 1
我想将消息发送到JMS队列，并在的通道上接收它。<?xml version="1.0" encoding="UTF-8"?/integration/spring-integrat
浏览 4提问于2012-06-24得票数 2
1回答
(UnicastingDispatcher.java:138) ~[spring-integration-core-5.1.3.RELEASE.jar:5.1.3.RELEASE]
at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:105) ~[spring-integration-core-5.1.3.RELEASE.jar:5.1.3.RELEASE
浏览 2提问于2019-02-27得票数 2
回答已采纳
1回答
在使用了一些抽头来丰富消息之后，我已经创建了自己的聚合器来重新组合产生的消息。但是，当我向这个流发送我通常的元组消息<e
浏览 4提问于2016-01-14得票数 1
回答已采纳
在我们的应用程序中，我们使用了Spring Integration和ActiveMQ。我们面临着一个问题，比如每当ActiveMQ服务器宕机时，应用程序就会抛出：org.apache.activemq.ActiveMQConnectionFactory!createActiveMQConnection!293
org.apache.<e
浏览 24提问于2014-07-02得票数 0
1回答
因为ActiveMQ是一个消息代理。我指的是这里给出的项目->
但我想知道如何在ActiveMQ中持久化消息。我的意思是我启动了ActiveMQ，然后使用REST客户机发送请求。我在循环中调用publishService.send( message ); 50次，接收端有10秒的睡眠定时器。使50条消息在10秒间隔内排队并开始处理。但在此期间，我停止了ActiveMQ服务器，到它消耗掉50条中的5条消息<em
浏览 2提问于2015-10-14得票数 2
在使用嵌入式代理关机时，我得到以下错误：我可能配置错了什么吗？我在这里使用了activemq页面上详细说明的配置：
(底部标记为"using spring-2.0“的配置)。消息传递正
浏览 0提问于2011-11-30得票数 3
回答已采纳
云服务器
ICP备案
云直播
实时音视频
即时通信 IM
腾讯云开发者
