2回答
实现持久的发布/订阅？
、、、
我在考虑使用队列:每个监听器创建自己的队列，并向发布者发送一条带有队列位置的订阅消息。发布者将该位置保存到一个文件或DB中，并开始向该队列发送消息。Publisher已启动。目前还没有监听器。发布者发送消息2。侦听器1启动并订阅publisher。监听程序1接收消
浏览 2提问于2011-05-27得票数 0
回答已采纳
我正在尝试在同一个队列上配置两个监听器，相同的交换，但只有路由关键字应该不同。我的问题是，不知何故，事情变得一团糟。结果是监听器A收到了发往监听器B的消息。但只是有时，有时一切都很正常。Header(AmqpHeaders.CORRELATION_ID) byte[] correlationId) {
}
附加信息:我在这个队列中有
浏览 9提问于2017-01-24得票数 2
回答已采纳
在我的例子中，假设有50个JMS队列接收不同类型的消息。
如果我实现了50个JMS侦听器(每个队列一个)，它就能很好地工作。但是，当所有50个队列都有许多挂起的消息时，我的所有50个JMS侦听器都在同时工作(即，将有50个JAVA线程在工作)。比方说，一次最多只能有10个活跃的监听器。有时监听器01~10在队列01 ~10上工作，有时监听器11~20在队列11~20上工作，等等。即使有新的消息进入<
浏览 1提问于2016-04-01得票数 0
1回答
JMS如何读取队列中的多个文件
、、、、
我正在处理的应用程序侦听一个队列。此队列从上游接收多个文件(买入/卖出订单)。我是这个应用程序的新手，正在尝试理解多个文件是如何处理的。我们使用camel来监听队列。我知道camel监听队列，当一个文件进来时，它会读取它，并将它路由到一个java文件来处理它。我的问题是，与此同时，有第二条或100条消息到达队列。当其他线程路由消息时，这些多个文件handles..would camel是如何产生一个新线程来保持监听<
浏览 1提问于2018-06-11得票数 0
我们有一个需求，我们需要停止一个监听器从一个队列中轮询消息，同时我们需要启动另一个监听器来从单独的队列中读取消息。我们如何才能做到这一点？我们是否可以开发一个cronjob来启动/停止监听程序在预定时间轮询相应的队列？
浏览 0提问于2018-06-28得票数 1
1回答
Java程序将消息发送到队列，另一端的侦听器拾取消息。我知道这可以通过监听器发送一个响应到回复队列来实现。但是JMS基础设施有没有内置的字段来告诉发送者监听器何时选择了消息。
消息传递系统符合JMS规范。
浏览 0提问于2012-01-11得票数 0
我能够执行REST删除操作来接收和删除来自Azure服务总线queues.To的消息，执行此操作我们需要外部调用REST api。是否有任何功能来执行轮询，一旦消息通过REST API在队列中可用，我们就应该自动拾取消息，而不需要外部调用来启动从队列中拾取消息。
可以通过REST连续监听队列中的消息吗？
浏览 0提问于2018-06-21得票数 0
1回答
活动MQ使用者仅接收替代消息
、、、、
要求:一个activemq队列应该在一台机器上运行(比如machine1)，而监听器只能在机器1上运行另一台机器(比如machine2 )来访问.That队列。因此，我发送给machine1和machine2的所有消息都应该进入队列，在machine1中可用，并且应该由同一台机器( machine1 )上可用的监听器接收。问题:我发送到machine1和machine2的所有消息都进入了队列，但监听器只接收到1、3、5的替代messa
浏览 3提问于2013-05-16得票数 0
1回答
它们有正在运行的服务，侦听器在队列'test‘上。我也有监听者。但是我不能把brokeredMessage放在我的监听器上。我可以关闭其他监听程序来获取我的服务的brokeredMessage吗？
浏览 0提问于2020-05-04得票数 0
2回答
JMS代理- WSO2消息选择器
、、、、
我们让WSO2 ESB监听单个ActiveMQ队列。但是，我们希望在监听JMS队列时配置多个代理。然而，我们希望代理只使用为它准备的消息。是否有一种机制可以在ESB代理上设置JMS消息选择器，以便它只使用为其指定的消息。？
感谢Rajiv Patil
浏览 0提问于2013-08-08得票数 0
1回答
我正在尝试弄清楚WSMQ是如何处理消息侦听器和线程的。如果我有一个消息监听器的实例，并且有许多队列，那么每个监听器是否为每个队列创建一个新线程？或者会有一个线程给监听器吗？
浏览 2提问于2009-10-06得票数 2
我们有两个不同的应用程序，它们通过发送消息与每个应用程序交互。有可能有多个监听器监听同一个队列吗？也许我们可以在将消息推送到队列时传递一些标头，然后根据标头，消息将到达单个消费者。
浏览 11提问于2018-08-06得票数 1
回答已采纳
可以在websheremq.I中使用事件驱动监听吗?我的意思是，当一个消息写入队列时，我应该每次都拉吗?你有可能使用消息驱动还是事件驱动监听吗？我必须做什么监听队列策略？
浏览 16提问于2018-02-20得票数 0
2回答
Web App有一个监听器，多个生产者，多个WorkerBee。侦听器将消息从其队列推送到WorkerBee。生成的所有消息都在侦听器中排队。我想实现一个可以使用某种负载平衡进程将消息从侦听器队列发送到每个WorkerBee的进程。在侦听器队列或WorkerBee队列中只出现一个消息实例。
做这件事最好的方法是什么？如何将消息从监听器队列推送到WorkerBee队列</em
浏览 0提问于2013-04-02得票数 0
回答已采纳
我使用的是ActiveMQ版本5.7.x，
我有一个监听器监听的ActiveMQ队列。队列有一些好消息和坏消息。当监听这样的队列时，当坏消息到来时，它们被尝试3次，等待时间为5000毫秒，但随后好消息被阻止了那么长的时间跨度。我想要的是，在每次重试5000毫秒的等待时间内，好消息的处理应该继续，而不应该等待坏消息的处理。
浏览 3提问于2014-06-19得票数 3
我们正在开发一个监听或使用来自RabbitMQ队列的消息的服务。消息从Apache Nifi分派到消息队列(例如，队列名为“workitem”)。现在，我希望看到一个使用Spring Integration的代码片段，用于侦听和处理从Apache Nifi发送到队列(RabbitMQ)中的消息。 谢谢!
浏览 29提问于2020-04-21得票数 0
回答已采纳
我有一个MSMQ队列，我需要实现一个监听程序，该监听程序定期或在指定的时间(即每晚)执行，以处理队列中的消息。例如，我需要每小时检查一次队列，如果有任何消息-处理它们。是否可以将WCF服务配置为使用有限数量的线程(例如2个
浏览 1提问于2012-02-05得票数 0
我想从该队列中获取消息，所以我在spring boot应用程序中使用以下依赖项创建了消息侦听器： <dependency> </dependency> 在那之后，我做了这样的场景: 1.启动spring boot应用2.向队列发送消息问题是
浏览 28提问于2020-04-01得票数 2
回答已采纳
1回答
我在oracle中创建了一个AQ，并用Java编写了两个JMS使用者来监听队列。我有时观察到，如果我在队列中产生一些消息，则从队列中出队的消息计数会大于入队的消息数。这意味着有些消息会被消费两次。我已创建具有以下属性的队列：- multiple_consumers => FALSE
而JMS使用者正在CLIENT_ACKNOWLEDGE mode中工作。因此，我可以重复这个问题并解决上面问题，并确保在多个JMS使用者监听
浏览 1提问于2013-05-10得票数 7
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
