JMS + ActiveMQ:对数据的独占访问

文章/答案/技术大牛

发布

2回答

Spring JMS ActiveMQ使用什么来确定代理何时应该切换独占使用者？

spring、grails、jms、activemq、spring-jms

Activemq中的独占消费者是指从代理发送的每条消息，直到消费者死亡或离开，此时代理切换消费者。是什么定义了切换发生的时间？如何在Spring JMS/ActiveMQ中对其进行配置？

浏览 2提问于2014-12-01得票数 0

0回答

jms、activemq

1)我有一个简单的应用程序，创建JMSProducer，ActiveMQ查询和发送一些消息查询。我为我的订阅者应用程序创建了另一个服务器配置，并在不同的端口上一次启动两次。问题是:我如何配置subscriber-Application，让它独占访问数据？主要条件是:如果我的队列中只有一个

浏览 7提问于2017-12-04得票数 0

回答已采纳

1回答

如何使用Grails和JMS / ActiveMQ配置独占消费者？

grails、jms、activemq、spring-jms

我有一个Grails应用程序，它使用JMS插件订阅给定的ActiveMQ主题。如何使TestService类成为独占消费者？我的用例是，我在亚马逊EC2上运行消费者，ActiveMQ提要的持久性为5分钟，如果实例死了，它需要更长的时间来替换实例。我不能丢失消息，必须保留消息顺序，因此我希望使用多个实例，其中要连接的第一个实例将是代理发送每条消息的实例，而其他实例处于备用状态。在第一个实例死亡的情况下

浏览 0提问于2014-12-01得票数 0

1回答

使用ActiveMQ/JMS主题的并行测试

java、spring、spring-boot、jms、activemq

我在Spring Boot JMS项目上有一个vm://localhost内存中的activemq设置。我的控制器将事件发送到特定的主题，一些测试检查事件是否通过@JmsMessagingTemplate正确发送。问题是当我同时执行多个测试时，一些pf会失败，因为它们得到了意外的事件。我尝试了确认模式、并发用户、独占用户、jms.listener.max-concurrency、activemq池配置……

浏览 0提问于2017-10-24得票数 0

1回答

我是否可以在不使用Administration Console的情况下获取JMS队列详细信息？

java、jms

我想获取JMS的所有详细信息，比如所有队列是什么以及存在多少消息。我可以从后端获取所有这些详细信息吗？如果有任何文件存储所有这些详细信息，我可以查看。有什么需要帮忙的吗？

浏览 25提问于2020-06-14得票数 0

3回答

是否可以使用STOMP将消息发送到多个队列？

message-queue、activemq、hornetq、stomp

我正在寻找一个PHP项目中的RabbitMQ替代品。到目前为止，我正在考虑的两个选择是Kestrel和Qpid (如果我们决定坚持使用AMQP (我希望避免使用AMQP))。在RabbitMQ中，您可以将消息发送到交换(目的地)，交换(目的地)决定消息应该发送到哪些队列或主题(在JMS术语中)。阻止我选择STOMP服务器(ActiveMQ/Apollo或HornetQ)的原因是，我无法确定在STOMP中是否可以将消息发送到目的地，以便将消息传递到多个队列(在JMS术语中)？

浏览 2提问于2012-04-04得票数 1

回答已采纳

2回答

ActiveMQ不使用JMS获取队列大小

java、activemq

我需要一种在ActiveMQ中不使用或获取队列大小的方法。是否有使用ActiveMQ API获取队列大小的解决方案？

浏览 6提问于2016-07-24得票数 3

回答已采纳

2回答

ActiveMQ Artemis -使用JMS获取可用地址列表

java、jms、activemq-artemis

最近，我不得不从ActiveMQ 5.X切换到ActiveMQ Artemis，用于我正在进行的项目。我有一个函数可以读取可用的主题并在MySQL数据库中填充一个表，但是该函数不再适用于Artemis中方法的更改。下面是我需要这个功能的原因：使用者连接到该地址名并生成队列。Java使用者/生产者每秒钟用网站的可用地址更新数据</

浏览 22提问于2022-04-17得票数 0

回答已采纳

1回答

如何在ActiveMQ中实现虚拟主题功能

activemq-artemis、virtual-topic

ActiveMQ“经典”具有功能。这意味着可以动态地创建消费者。这个特性是如何由ActiveMQ Artemis管理的？

浏览 12提问于2022-03-29得票数 1

2回答

在侦听器使用camel接收到JMS消息之前，如何延迟队列中的JMS消息？

jms、apache-camel

我的带有驼峰配置的弹簧如下所示。<bean id="jms" class="org.apache.camel.component.jms.JmsComponent"> <route id="routeOne" delayer="100

浏览 3提问于2015-11-05得票数 0

1回答

ActiveMQ代理RedeliveryPlugin消息存储

java、jdbc、activemq

我们正在考虑使用JDBC数据存储来建立一个由3个代理组成的主/从网络。根据文档，这将导致一个代理获取JMS表上的独占表锁，从而成为主程序。其他经纪人将不会完全启动和等待，直到他们可以获得锁，成为新的主人。如何存储等待由ActiveMQ Broker 重新传递的消息？它们是否也持久化在JDBC数据存储中，或者它们是代理本地的，并且不会故障转移到下一台机器？

浏览 0提问于2014-08-01得票数 0

回答已采纳

2回答

哪一层协议是OpenWire

java、jms、activemq

另外，OpenWire是ActiveMQ用来在JMS客户端之间通信的默认协议吗？我查看了文档，但什么也找不到。

浏览 15提问于2018-01-29得票数 3

2回答

Groovy中具有ActiveMQ的JMS* -无法解析类ActiveMQConnectionFactory*

groovy、activemq

我正在尝试我的第一个groovy JMS示例:也可以看到。这样做了，但类仍然没有得到解决。@Grab(group='net.sf.gtools.jms', module='JmsCategory', version='0.2')@Gra

浏览 1提问于2013-10-30得票数 2

2回答

使用Apache Camel和Active MQ对应用程序中的消息进行诊断和统计

jms、activemq、apache-camel

在我的受干扰的java应用程序中，我使用Apache Camel和Active MQ进行节点之间的通信。我想在Active MQ中存储关于队列的相同数据。我想做一个统计，并自动检测队列是否没有超载。我找不到Apache Camel和Active MQ提供的任何工具来做这些事情。你知道吗？或者也许我只是在文档中遗漏了一些东西。

浏览 1提问于2013-06-21得票数 1

回答已采纳

2回答

JMS和ActiveMQ

java、spring、jms、activemq、message-queue

我需要编写一个在消息队列上侦听(使用者)并将它读取的数据发送到数据库的服务器，以及另一个将信息(生产者)发布到这个队列的服务器。 FileSystemUtils.deleteRecursively(新文件(“activemq

浏览 3提问于2016-05-23得票数 1

回答已采纳

1回答

ActiveMQ Artemis:虚拟主题和死信队列

activemq-artemis

我们正在从ActiveMQ“经典”迁移到ActiveMQ Artemis。在ActiveMQ“经典版”上，我们使用的是虚拟主题。使用该设置，当在虚拟主题使用者队列上未传递消息时，它将被放置在以.Dead后缀的同名队列中。在ActiveMQ Artemis上，我们通过设置OpenWire参数virtualTopicConsumerWildcards=Consumer.*.>;2来再现这一结果。</address-setting> 结果是，当消息未被传递时，它结束

浏览 14提问于2022-10-12得票数 0

回答已采纳

1回答

在将消息发送到ActiveMQ之前对其进行池化

java、jms、activemq

要求是从Tomcat通过JMS (最有可能是ActiveMQ)发送网站访问者生成的表单数据。有两种相互竞争的想法-一种是利用中间存储和线程池来发送到队列(如果发送到JMS由于某种原因失败，则尝试重新发送)，另一种是尝试直接通过JMS从处理访问者的post请求的线程发送有效负载-如果JMS发送由于某种原因失败第二种选择对我来说似乎更好，因为我认为在消息队列前面添加中

浏览 1提问于2015-01-16得票数 1

2回答

如何使用ActiveMQ* (OpenWire)重新定义修改后的消息？*

activemq、marshalling

首先对我想做的事做个小小的解释。我正在编写一个Java (1.7)应用程序，它将尝试使用从生产者到目标消费者的OpenWire格式“模糊”通过OpenWire发送的XML消息。我有单独的程序来生成这些消息的示例实例，并标识在发送的有线格式中找到信息的位置(本例中为OpenWire)。这些信息将用于模糊处理，以了解要更改的数据的位置。如果修改导致长度更改，则到ActiveMQ

浏览 0提问于2018-07-05得票数 0

回答已采纳

1回答

从ActiveMQ“经典”升级到ActiveMQ* Artemis类java.util.ArrayList不是有效的属性类型。*

activemq、spring-jms、activemq-artemis

我正在将ActiveMQ“经典”升级到ActiveMQ Artemis，同时维护客户端代码。我有多个地方的代码像这样。("mytest", map); 如何修复来自上述代码的以下错误。occurred during JMS processing; nested exception is javax.jms.JMSException: org.apache.activemq.artemis.api.core.ActiveMQProp

浏览 8提问于2022-09-08得票数 0

回答已采纳

2回答

作为JAR项目运行的Spring JMS

spring、jar、project

我有一个Spring JMS应用程序。事实上，这里没有UI。只有Spring配置(JMS listener)和Spring配置由web.xml加载。因此，当我在服务器中部署时，侦听器开始工作。但我不想要web部件，因为没有UI，它只是一个侦听队列并进行处理的项目。所以我认为它应该是JAR，它应该独立运行(或者当我在服务器上部署时)如何创建这样的项目/ JAR当部署到服务器上时，它会自动开始运行。我不希望每次更新JAR时都运行一个主类。

浏览 0提问于2012-09-18得票数 3

回答已采纳

点击加载更多

Spring JMS ActiveMQ使用什么来确定代理何时应该切换独占使用者？