-
1 votesanswersviews
骆驼中的正则表达式匹配器
我试图想出一个骆驼路线，只有当匹配给定的正则表达式时，才会将消息发送到jms队列 . 我的路线是这样的： <route id="testRoute"> <from uri="jms:queue:Q.Order1" /> <choice> <when> ... -
1 votesanswersviews
ActiveMQ消息未出列，直到访问Web管理列表
我们的架构基于一个由大约70个队列组成的ActiveMQ 5.10.0主干网 . 不同的应用程序将消息发送到队列，不同的应用程序消耗来自队列的消息 . 具体来说，只有5个队列拥有多个消费者，而其余队列每个队列只有一个消费者 . 除了拥有多个消费者的队列之外，一切正常 . 对于这些队列，消息正确排队，但它们不会出列，直到我们访问ActiveMQ Web门户并单击队列名称，从而登记完整的消息列表 . ... -
0 votesanswersviews
在Activemq中的同一连接中创建使用者和临时队列？
我是activemq的新手 . 当我为临时队列创建一个消费者时，消费者给出了在session.it中创建的临时队列的点 . 它将是一个同步进程 . 之后它将产生消息给broker（activemq） . 代码如下 // client side Destination tempDest = session.createTemporaryQueue(); MessageConsumer respo... -
1 votesanswersviews
虚拟主题中的消息未被消费者队列消耗
我试图在activemq中使用队列来从虚拟主题中出列消息 . 我尝试发送一些消息，它出现在“消息排队”下的主题中，但它无法被消费 . 我创建的虚拟主题名称是VirtualTopic.AA，消费者称为Consumer.client1.VirtualTopic.AA . 在consumer.client1.VirtualTopic.AA中，我可以看到有一个消费者，但它无法从虚拟主题中取消消息 . 谁知... -
0 votesanswersviews
ActiveMQ队列：选择器和独占消费者
我正在尝试使用具有多个订阅者的队列（每个订阅者具有唯一的选择器）以及将destination.consumer.exclusive标志设置为true . 但是当我向这个队列发布消息时，我看到该消息在队列中可用，但是尽管满足消费者的选择标准之一，但没有一个订阅者已经将其取消 . 我在AMQ UI控制台上看到以下详细信息： 待处理消息数 - 1 消费者数量 - 6 已排队的消息 - ... -
0 votesanswersviews
哪种类型的Spring Integration Channel？
我在ActiveMQ中有一个队列，并希望使用spring集成将消息从它中删除到我们的应用程序中 . 我们已经部署了两次应用程序（如果其中一个失败） - 每个消息应该只由其中一个应用程序处理 . 另外，在消息处理期间，如果致命的应用程序失败，我需要一个jms tx管理器 . 因此我的通道适配器看起来像这样： <int-jms:message-driven-channel-adapter ... -
1 votesanswersviews
jboss中的JMS队列重新传递顺序
我从一个线程发送一个java对象到一个队列 . 使用队列中的消息调用相关MDB的onMessage . onMessage，我将消息中的密钥与缓存中的密钥匹配，如果密钥不存在，我抛出一个自定义的runtimeexception只是为了让容器重新发送此消息 . （我有另一个自治系统，它从外部系统响应中添加缓存的密钥，它可能会慢到3-5秒）在这种情况下，此容器是否将此未处理的消息添加到队列的末尾，... -
0 votesanswersviews
为什么ActiveMQ在重新安排重新安排之前将消息传递了6次？
我正在使用apacheMQ作为队列管理器 . 我正在使用Spring的DefaultMessageListenerContainer来使用消息 . 我已配置它，因此它有一个事务： <bean id="jmsContainerXXX" class="org.springframework.jms.listener.DefaultMessageListenerCon... -
2 votesanswersviews
ActiveMQ中的setBackOffMultiplier（double backOffMultiplier）如何工作
我正在使用activemq编写应用程序，我正在使用重新传递策略来重新传递消息 . 我正在使用ActiveMQ的ExponentialBackOff概念 . 我的问题是这个ExponentialBackOff / setBackOffMultiplier是如何工作的 . 例如，在我的情况下，我想重新发送消息，直到消息到期时间为15分钟 . 我想尝试在15分钟内重新发送10次 . 但Exponenti... -
1 votesanswersviews
显式的acking消息时是否需要打开ActiveMQ使用者？
我的应用程序通过从ActiveMQ读取消息来进行批处理 . 我通过实现 MessageListener 来阅读使用异步JMS API . 但是，只有在批处理成功时才通过调用 message.acknowldge() [1]来确认消息 . 我理想的是，在批处理进行之前，我没有收到来自JMS代理的任何消息 . 但我怀疑在关闭消费者之后，我是否能够确认我之前读过的消息以及正在处理的消息 . 换句话说，... -
4 votesanswersviews
尽管producerFlowControl为false，但activemq缓慢消费者阻止 生产环境 者
我在我的系统中使用activemq，我看到的是以下消息：TopicSubscription：consumer = ...：Pending message cursor [org.apache.activemq.broker.region.cursors.VMPendingMessageCursor@1684f89c]已满，临时使用（达到0％）或内存使用率（100％）限制，阻止消息add（）等待资源... -
0 votesanswersviews
在消费者缓慢的情况下如何阻止 生产环境 者
我从ActiveMQ文档here中读到以下引用： 使用同步消息传递的缺点是，如果消费者调度消息的速度很慢，则 生产环境 者更有可能阻止 . 但是我不明白 生产环境 者通常如何因为消费者的缓慢而被阻止，因为我的理解是JMS客户端（ 生产环境 者）将消息发送到ActiveMQ实例（代理）的队列，就是这样，现在 生产环境 者是免费的，换句话说 生产环境 者线程发送消息是免费完成/死亡 . 然后会有一... -
0 votesanswersviews
DefaultMessageListenerContainer和ActiveMQ线程管理
我've done some tests with ActiveMQ and Spring JMS. I'已配置 DefaultMessageListenerContainer （DMLC）与 WorkManagerTaskExecutor 和CommonJ来管理线程 . 我想控制在服务器上运行的线程 . 我根据Juergen Holler在Spring的论坛上发表的帖子做出了使用DMLC的决定：... -
0 votesanswersviews
DefaultMessageListenerContainer未从ActiveMQ队列接收所有消息
ActiveMQ / Spring专家， 我遇到了ActiveMQ和 DefaultMessageListenerContainer / SimpleMessageListenerContainer 组合的一个非常奇怪的问题 . 我们有一个使用Spring构建的Web应用程序（我们在4.x） . 其中一个事务与处理文件的批量上载有关，每个文件都有多行 . 每一行都将成为处理消息 . 发布者将每... -
4 votesanswersviews
试图测试队列持久性 . 消费者断点时无法发送消息
我正在尝试测试ActiveMQ的队列持久性 . 我有一个嵌入式ActiveMQ服务器，具有独特的消费者 . 此嵌入式服务器从许多其他JVM应用程序接收JMS消息 . 它工作正常，消费者应用程序接收通知 . 所以我试图测试消息的持久性 . 我在消费者的MessageListener上放了一个（远程）断点，这样我就可以排队很多消息并使ActiveMQ服务器崩溃 . 在服务器重启时，我希望能够使用所有排... -
0 votesanswersviews
ActiveMQ Consumer不会确认该消息
我有ActiveMQ 5.14.5的问题 . 我有几个应用程序（例如，Spring事务处理DefaultMessageListenerContainer或Scala Alpakka与会话事务处理），它从该代理程序中消耗 . 事实证明，有些消费者（我们拥有的每种类型的应用程序）都会收到消息，处理它们，但是确认/提交不会到达代理 . 消费者处理所有消息，直到预取限制，然后代理停止向消费者发送新消息 .... -
5 votesanswersviews
需要澄清JMS与ActiveMQ bean /资源配置
在如何使用JMS资源以及在 @MessageDriven 注释上使用正确的 @ActivationConfigProperty 设置 activationConfig 似乎存在一些不一致 . 首先，这是我的资源配置（ glassfish-resources.xml ，但可以翻译成其他部署描述符） . 这适用于Glassfish（ asadmin add-resources glassfish-re... -
0 votesanswersviews
无法向远程Tomcat和ActiveMQ队列发送消息
我在Tomcat ActiveMQ服务器上配置了一组JMS队列 . 我已经为connectionFactory创建了一个Resource（通过将Broker指向tcp：localhost：61616），并在全局资源中的Server.xml中为Queue创建了一个资源，然后在context.xml中声明了这两个资源 . 现在我正在尝试从另一个tomcat服务器连接此队列并发送消息 . 当试图用jnd... -
4 votesanswersviews
Spring Integration - 使用JMS和网关的请求/回复消息传递
我使用SpringIntegration 2.2.1时遇到问题：我想使用JMS（WMQ作为代理）在两个不同系统之间交换消息，在JBoss AS 7中实现请求/应答模式（作为同步消息传递） . 我的xml配置文件包含： 1) 出站配置： <bean id="BOHAdjustmentConverter" class="com.test.interoperabil... -
1 votesanswersviews
Spring JMS出站通道适配器
我是Spring Integration的新手 . 我缺乏它的基础知识 . 我们有一个要求，即轮询一个状态为0的oracle数据库表，并以XML格式将该记录发送到JMS队列 . jdbc：入站通道适配器正在拾取记录并转向jms出站通道适配器，这应该非常简单 . 但我有两个问题 1）我看到有多少消费者在activeMQ管理控制台中有1个用于我的需求和配置，所以我不想在队列上监听所有我想要的消息是将消... -
3 votesanswersviews
如果超时或应用程序处理消息崩溃，消息会发生什么？
我目前正在阅读JAVA的同步JMS . 我想确认我的理解是否正确 . 基于我在Google中搜索的内容，我的理解是针对JMS同步方法，如果发生超时，则消息将永远丢失 . 我对么？ My question is: 如果发生超时，或者应用程序使用基于以下示例的同步JMS方法处理消息崩溃，该消息会发生什么？ 使用synchronous作为示例，其中系统A是消息的生成者，系统B使用和处理消息1：系统A将消... -
2 votesanswersviews
在JMS队列中插入消息，然后使用Spring Integration发回确认
我有一个服务，它通过http入站适配器接收xml消息，然后将它们转换为文本，成为发送出去的电子邮件的内容 . 我现在需要先将这些消息插入JMS队列，然后在将消息插入Q后将确认发送回200 ok，然后继续执行其余处理 . <int-http:inbound-channel-adapter channel="inputChannel" id="httpIn... -
1 votesanswersviews
Spring Integration Jms出站通道适配器不向队列发送消息
您好我正在使用Spring Integration项目连接到IBM MQ.Below是connectionFactory和Queue的代码 <bean id="mqConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory"> <property nam... -
1 votesanswersviews
在运行时更新jms入站适配器目标
我正在创建一个简单的spring集成应用程序，它将消息发送到可配置的jms队列，并从不同的可配置jms队列接收消息 . 我能够使用“destination-expression”配置出站jms适配器队列，但由于这对入站适配器不起作用，我不确定如何执行此操作 . -
0 votesanswersviews
Jboss EAP 6.4中不同Message提供程序的多个资源适配器是否共享默认的bean-instance-pool？
我们正在使用JBoss EAP6.4 . 在我们的项目中，我们使用两个MOM：1）Websphere MQ 2）Solace MQ这是我们在standalone.xml中定义的两个MOM的资源适配器的方式 <?xml version='1.0' encoding='UTF-8'?> <server xmlns="urn:jboss:domain:1.7">... -
1 votesanswersviews
Spring jms activemq
我使用activemq和spring jms . 我有个问题 . 这是我的EmailSender @Service @PropertySource("classpath:/properties/dev/application.properties") public class EmailSenderImpl implements EmailSender { privat... -
6 votesanswersviews
Spring集成
我们的应用程序是使用Spring Integration Framework设计的 . 完成消息动作流程开始于监听已使用JMS消息驱动适配器的Queue，之后已定义基于通道的队列 endpoints ，并且每个 endpoints 由Service-Activators处理 . 我们目前正处于性能阶段，我们正在产生200条消息请求 . 最初我们观察到消息没有并行执行，在做了一些阅读后发现通过将并发... -
0 votesanswersviews
将应用程序重新部署到weblogic服务器时，消息驱动的通道适配器不轮询消息
在Web逻辑服务器中重新部署Spring Integration应用程序后，消息不会通过重新启动服务器获得消息驱动通道适配器，消息将再次进入Spring集成应用程序 . 使用跟踪日志表示虽然只是发送了消息但没有收到消息 . 甚至完全maven部署 - Stop-app -.Undeploy - > Deploy -.Start-app . 我正在使用默认消息侦听器配置和消息选择器 . 以... -
0 votesanswersviews
我可以为JNDI的主题提供一个带有两个MessageListener的DefaultMessageListenerContainer吗？
我想创建两个MessageListeners . 我有一个主题，我可以使用JNDI（名称：jms / eventsTopic）接收 . 我知道可以创建以下配置： <jms:listener-container ... <jms:listener destination="topic" ref="listener1" /> &... -
1 votesanswersviews
用于队列的ActiveMQ多个MessageListener似乎无法正常工作
场景是，我设置了两个DefaultMessageListenerContainer，如下所示： DefaultMessageListenerContainer container = createListenerContainer(queueName, groupName, listener); container.setDestination(getDestination(queueName, ...