2回答
假设我有几个订阅者从一个主题中消费。在将消息传递给所有订阅者之后，我希望触发一个在输入中使用此消息的作业。因此，实现这一目的的简单方法是将已成功传递给所有抄写者的消息移动到队列中，我的工作将从队列中消耗消息。它是JMS的一部分吗？
有任何消息代理可以直接这样做吗？如果没有，是否有一个简单的解决办法来解决这个问题？
浏览 0提问于2013-10-30得票数 0
回答已采纳
1回答
我是Activemq和Java的新手，我阅读教程，有些时候我understand.can任何人帮助我解决以下任务。我想编写两个Java应用程序(使用JMS接收来自Activemq的消息)，它们将在activemq中充当消费者。我想要实现的</
浏览 0提问于2013-09-05得票数 0
我希望能够为同一个JVM中的嵌入式ActiveMQ (5.4.2)代理获得从java监听某个主题的消费者数量。JMX真的是这里唯一的选择吗？JMX似乎是一个糟糕的选择，因为它可能被选择性地禁用。这篇文章展示了如何使用JMX获取连接列表：
我更喜欢基于非JMX的解决方案，尽管它可能会被禁用。我想如果JMX在被禁用时仍然可以在java中使用，那就没问
浏览 4提问于2012-04-24得票数 10
回答已采纳
1回答
Kafka多消费者监听多个主题
、、、、
我们正在开发一个应用程序，在该应用程序中，我们希望在Kafka中收听多个主题。所有主题都有一个单独的分区。所有的主题名称都有一个共同的前缀，比如“topicPattern -x”，"test-y“，所以我们可以使用spring。我们想要编写一个使用regexp模式监听所有主题的java spring使用者。我们的想法是，我们可以运行同一消费者(属于同一组
浏览 2提问于2018-03-22得票数 0
我正在从ActiveMQ“经典”5.15.4迁移到ActiveMQ Artemis 2.17.0，并观察到性能下降。我测试了一个主题的一个生产者和不同数量的消费者使用这个主题。我正在测量从信息创建到消费者接收消息之间的时间。
测试是在一个由3个节点组成的集群上进行的，每个节点都相互连接。每个代理都嵌入到一个JBoss中。我使用了一个由3个节点组成
浏览 4提问于2021-10-05得票数 3
回答已采纳
2回答
我将在我的一个项目中第一次使用ActiveMQ (持久消息主题)。我读到持久消息会强制限制每秒消息的数量。我应该意识到的其他因素(例如，缓慢的消费者)限制了activemq的规模和性能特征，应该密切监控哪些指标，以及所有地狱破解损失的值是什么。目前，我不希望在ActiveMQ中每秒推送超过1000个事件。
浏览 0提问于2011-09-19得票数 6
回答已采纳
我必须在Java中开发实用程序，它将使用ActiveMQ API来获取队列/主题的属性，以获得挂起消息的用户/对象的编号，还有什么方法可以从队列中删除任何消息代码吗？
浏览 2提问于2015-09-16得票数 0
回答已采纳
我在代理集群的ActiveMQ网络上有一个JMS主题(也称为分布式主题)。我有一个外部JMS使用者(Weblogic门户)，它需要订阅此主题并获取发送给它的所有消息(跨所有代理)。如果消费者在其中一个代理上订阅了主题，它将只获得代理收到的消息的子集，对吗？
我想我可以为每个代理创建一个消费者，并将消息聚合在一起，但然后我也要处理连接问题，并需要知道哪些代理是可用的
浏览 2提问于2010-02-13得票数 5
回答已采纳
我正在尝试通过JUnit测试从嵌入式ActiveMQ获取我的主题的订阅统计数据。我能够订阅该主题，向该主题发送消息，并且能够在我的听众/订阅者中接收该消息。但是，当我尝试从ActiveMQ获取统计信息时，消费者接收超时。如果我不添加"receiveTimeout“，那么消费者将无限期地等待消息。下面是我<em
浏览 4提问于2016-04-11得票数 1
1回答
我想在java Spring boot项目中使用JMS队列和主题。因此，对于主题，我必须在application.properties spring.jms.pub-sub-domain = true中使用此主题。现在在同一个项目中，我也想接收队列消息，购买ActiveMQ没有看到我的队列的任何消费者…我怎么才能让它工作呢？用于从ActiveMq本地主机发送邮件的JmsListener示例:8161
浏览 16提问于2016-08-29得票数 1
回答已采纳
团队，我们有一个发布者，它发布请求主题的消息，并假设我们有2个消费者实例正在运行。这两个实例将从topic获取消息。一个消费者处理时没有任何问题，但其他消费者在处理过程中崩溃。因为它是不可持久的，所以当消费者获取消息时，消息已经从请求主题中删除了。现在我们不希望两个消费者都完成了，消息应该在happen.Unless中可用。我们不能在这种情况下使
浏览 2提问于2018-12-07得票数 0
我正在将现有代码从使用ActiveMQ 5.x迁移到使用Artemis。使用org.apache.activemq.ActiveMQConnectionFactory时，我的虚拟主题使用者队列中有消息发送给排队的虚拟主题。" value="${activemq.connectionPool.sessionsPerConnection}" />对于虚拟主题</e
浏览 3提问于2021-04-20得票数 0
回答已采纳
我使用Spring4.x的DefaultJmsListenerContainerFactory连接到ActiveMQ队列，使用@JmsListener处理来自该队列的消息，然后将消息推送到同一个ActiveMQ代理上的主题。我还将并发设置为1-3，我希望在应用程序启动时队列中至少有一个消费者，随着消息的增加，消费者的数量将达到3。然而，随着消息数量的</e
浏览 8提问于2016-09-09得票数 5
回答已采纳
1回答
我有一群tomcats，它们使用来自ActiveMQ主题的消息。现在，如果集群中的一只tomcat宕机，那么我猜消费者的数量将减少1。
现在，我想使用一些关于该主题的回调或侦听程序来检测这种变化。像: Region.getDestinations(ActiveMQDestination)这样的东西会起作用吗？
浏览 0提问于2017-04-10得票数 1
1回答
(PrefetchSubscription.java:214) at org.apache.activemq.broker.TransactionBroker.acknowledge(TransactionBroker.java(TcpTransport.
浏览 0提问于2015-01-14得票数 3
例如，我们有一个持久的主题消费者和一些该主题的代理。据我所知，代理将继续存储每条消息(在某些限制内)，即使持久消费者在很长一段时间内不是活动的。在ActiveMQ中是否有一些代理策略来销毁(自动取消订阅)非活动(在一段指定时间内)持久消费者？这样我就不需要监控所有的消费者是否仍然有效并且确实存在。
浏览 1提问于2011-03-11得票数 3
回答已采纳
是否可以将主题配置为只存储最后一条消息的副本并将其发送到新的连接，而不知道客户端标识符或其他信息？在activemq中包括policyEntry for topic=">"中的折页行
<subscriptionRecoveryPol
浏览 4提问于2014-02-26得票数 5
我有200个Kafka用户，他们可以做这些事情中的任何一个，1.他们可以订阅200个不同的主题，并将消费敏感的消息。2.所有200个消费者可以订阅单个topic。问题: 1.创建200个或更多的topic是一个好的设计吗? 2.在第二个场景中，我们如何实现发布到topic的消息只根据某个参数发送给特定的消费者。
浏览 0提问于2020-04-09得票数 1
当一个消息(MQTT (3.1) QoS1)没有客户端使用该底层主题时，它会物理地从KahaDB ActiveMQ (5.15)数据库中删除吗？例01：例02：
发送给主题"
浏览 4提问于2022-09-28得票数 0
我正在尝试以非编程方式读取在activemq中排队的主题messages。(用于调试目的)由于我是AMQ的新手，我可能完全迷惑了……有人能帮上忙吗？
非常感谢！
浏览 0提问于2012-12-19得票数 1
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
腾讯云开发者
