如何在JMS/ActiveMQ中使用同步来保持MessageConsumer的活动状态？
在JMS/ActiveMQ中，可以使用同步方式来保持MessageConsumer的活动状态。具体步骤如下：
- 创建一个Connection对象，用于与消息代理服务器建立连接。
- 创建一个Session对象，用于发送和接收消息。
- 创建一个Destination对象，表示消息的目的地，可以是队列（Queue）或主题（Topic）。
- 创建一个MessageConsumer对象，用于接收消息。
- 在MessageConsumer对象上调用start()方法，开始接收消息。
- 使用同步方式接收消息，可以通过调用receive()方法来阻塞等待消息的到达。receive()方法会一直阻塞，直到接收到消息或超时。
- 处理接收到的消息。
- 重复步骤6和7，以保持MessageConsumer的活动状态。
使用同步方式保持MessageConsumer的活动状态的优势是可以确保消息的即时性和可靠性。同步方式会阻塞线程，直到接收到消息或超时，因此可以及时处理消息并保持消费者的活动状态。
JMS/ActiveMQ中的相关产品和产品介绍链接地址如下：
- 腾讯云消息队列 CMQ：提供高可靠、高可用的消息队列服务，支持消息的发布和订阅，适用于构建分布式系统和异步通信。详情请参考：https://cloud.tencent.com/product/cmq
- 腾讯云消息队列 CKafka：基于 Apache Kafka 构建的分布式流式消息系统，具备高吞吐量、低延迟、高可靠性等特点，适用于大规模数据流处理和实时分析。详情请参考：https://cloud.tencent.com/product/ckafka
请注意，以上仅为示例产品，实际选择产品时应根据具体需求进行评估和选择。
相关·内容
我做了一个简单的ActiveMQ应用程序。
它听一个队列。如果收到消息，则打印出dataId
以下是代码：
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.ExceptionListener;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.MessageConsu
浏览 3提问于2013-06-17得票数 2
回答已采纳
嗨，开发商，
我想用.java库名称MessageProducer和MessageConsumer编写2个MessageProducer文件。
我将activemq-all-5.8.0.jar和commons-io-2.4.jar文件添加到我的lib folder.and中，将Activemq的端口号从61616更改为61617。
使用MessageProducer.java文件，我将向Activemq.For发送消息--这是我编写的代码--它正在工作--您想要看到的是单击这个。
我想从Activemq发送消息到MessageConsumer.java.This is Applica
浏览 1提问于2013-08-08得票数 1
A-问题
我知道有一个类似的问题，但不一样。
我正试图了解JMS中的MessageProducer和MessageConsumer在幕后发生了什么。使用MessageProducer ActiveMQ的实现，我编写了一个简单的示例以发送消息到队列，并编写了一个MessageConsumer示例来使用来自队列的消息，同时在本地运行ActiveMQ。
向队列发送消息需要Connection#start方法。确切的调试点如下所示。Connection#start触发ActiveMQSession#start方法。此方法是在调用Connection#start时触发的。请参见org.apache.ac
浏览 5提问于2020-10-02得票数 1
回答已采纳
2回答
我想写代码从Activemq中提取消息，.I不想一次从Activemq中提取所有消息，因为我的要求是每当我的Java应用程序从Activemq接收到一条消息时，根据消息体，我将找到相应的HTTP Link并转发到该链接。对于整个逻辑，我编写了2个.java文件名为
MessageConsumer.java
MyListener.java
仅用于连接establishing.The的MessageConsumer.java文件对应的代码在下面。
package PackageName;
import java.io.IOException;
import javax.servlet.Ser
浏览 1提问于2013-08-09得票数 3
回答已采纳
1回答
我们有一个JMS客户机，它需要处于空闲状态，直到收到消息。当它收到一条消息时，它将执行一些功能，然后返回到空闲状态。我的问题是，确保客户端保持正常运行的最佳方法是什么？让JMS客户端软件处理这个问题是很好的做法，还是我们需要将软件作为服务运行在主机上(和/或做其他事情)？我们目前依赖JMS客户端软件，因为它似乎使线程与打开的连接保持活动，但我不确定这是否是最佳实践。我们使用ActiveMQ作为消息代理和客户端软件。
编辑:添加代码示例
下面是一个示例，说明客户机如何使用JMS客户端连接保持未睡状态：
import javax.jms.Connection;
import javax.jms.D
浏览 0提问于2018-11-28得票数 0
回答已采纳
尝试让JMS MessageConsumer在ActiveMQ重启后继续运行，这样它就可以使用故障转移传输协议重新连接。
但是，它会在ActiveMQ关闭时终止。
这看起来像是报告并“解决”了一个错误，但我仍然在最新版本的ActiveMQ 5.10.0中看到了这一点
我使用了下面的maven依赖项
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-all</artifactId>
&l
浏览 15提问于2014-08-29得票数 1
我有一个浏览队列消息的spring-batch，这个队列应该包含大量的消息。然后需要花费大量的时间来治疗所有这些问题。因此，我考虑过使用多线程来解决这个问题，但我还不清楚。
下面是在不使用多线程的情况下浏览队列的示例：
import java.net.URISyntaxException;
import java.util.Enumeration;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Message;
import javax.jms.MessageConsumer
浏览 2提问于2019-07-01得票数 0
我有一个超级简单的场景:一个经纪人和一个持久订阅的消费者。这是我的消费应用程序的代码：
package test;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Sess
浏览 3提问于2014-04-15得票数 1
回答已采纳
3回答
ActiveMQ的测试用例
、、、、
根据建议使用ActiveMQ进行测试的答案，我想知道如何使用ActiveMQ测试JMS
但是，我没有从MessageConsumer收到我所期望的消息。如果我使用了接收，它就会挂在那里。
以下是我的代码
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jm
浏览 0提问于2012-05-05得票数 1
回答已采纳
1回答
我是JMS中的新手，我希望创建一个发送消息的基本MessageProducer和异步接收消息的MessageConsumer。当我运行这段代码时，会收到错误消息：
MessageProducer.java
package activemq.test;
import java.util.Date;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
public class MessageProducer{
javax.jms.MessageProducer producer = nul
浏览 5提问于2015-04-29得票数 1
1回答
看来，ActiveMQ中的持久主题(这似乎是JMS本身的一个障碍)，只有一个使用者可以在订阅服务器上活动。
也就是说，在ActiveMQ文档中：
使用唯一的JMS MessageConsumer和持久的订阅者名称创建JMS持久订阅服务器clientID。为了兼容JMS，只有一个JMS连接可以在一个JMS clientID的任何时刻处于活动状态，而对于一个clientID和订阅者名称只能有一个使用者处于活动状态。也就是说，只能从给定的逻辑主题订阅服务器主动使用一个线程。
然而，其他排队系统(看起来像Azure Service Bus这样做，基于文档)似乎很容易在单个“订阅”上允许多个线程
浏览 4提问于2017-11-09得票数 2
回答已采纳
2回答
由于某些原因，我无法创建一个持久的消费者，以摄取来自activemq的信息。我研究过和，但是使用最新版本(连同Java1.7)并没有解决这个问题。我一定是在使用错误的版本/实现，但是我还没有找到它的根源。以下是代码：
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.QueueSession;
import javax.jms.Session;
import ja
浏览 3提问于2014-07-10得票数 3
回答已采纳
我正在尝试运行，但在配置方面有一些问题。
我抄袭了log4j-jms.properties，jndi.properties，Log4jJMSAppenderExample.java
ProjectJMS
|
\_ src
| \_ Log4jJMSAppenderExample.java
| \_ jndi.propeties
\_ log4j-jms.properties
并在我的控制台中运行activemq。
当我运行我的例子，我得到
log4j:WARN No appenders could be found for logger (org.apache.activemq.tra
浏览 5提问于2012-08-13得票数 6
回答已采纳
我正在尝试使用ActiveMQ 5.x创建一个持久的消费者，因此我有以下内容：
private static void consumeFromTopic() throws JMSException, NamingException {
javax.naming.Context ctx = new InitialContext();
ConnectionFactory factory = (ConnectionFactory) ctx.lookup("ConnectionFactory");
Connection connection = factory
浏览 0提问于2019-05-19得票数 1
我尝试测试一个使用JMS2.0API使用JMS消息的应用程序。
为了降低测试的复杂性，我使用MessageProducer在测试中发送一条消息，并尝试在同一会话中使用MessageConsumer将其读取回来。
我使用一个符合JMS2.0的嵌入式ActiveMQ-Artemis2.5.0实例。
package be.attle;
import javax.jms.CompletionListener;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
浏览 2提问于2020-08-18得票数 1
回答已采纳
我在ActiveMQ中有一个MessageProducer和多个MessageConsumer。我想让消费者等到生产者发布一些东西。然后消费者可能会被终止。我正在尝试使用ActiveMQ同步来实现这一点，但它不起作用。我确实看到生产者产生了一些东西，但消费者没有对消息做出反应。 这是我的代码： 生产者类： import javax.jms.*;
import org.apache.activemq.ActiveMQConnection;
public class TopicProducer extends Thread {
private final String producer
浏览 9提问于2019-04-25得票数 0
回答已采纳
1回答
拥有Apache从文件夹到ActiveMQ主题的简单消息路由：
//Create context to create endpoint, routes, processor within context scope
CamelContext context = new DefaultCamelContext();
//Create endpoint route
context.addRoutes(new RouteBuilder() {
@Override
public void config
浏览 1提问于2014-11-03得票数 0
回答已采纳
我想在DefaultMessageListenerContainer中使用subscriptionShared和subscriptionDurable，因为在所有消费者之间有一个共享的持久订阅。
Tomcat启动后，我多次看到此日志消息，似乎我的主题有问题：
Setup of JMS message listener invoker failed for destination x.y.z trying to recover. cause:org.apache.activemq.ActiveMQSession.createSharedDurableConsumer (Ljavax/jms/To
浏览 7提问于2019-07-29得票数 1
回答已采纳
2回答
我试图在Apache中配置Active。我有两个war文件，MessageProducer.war和MessageConsumer.war，我在两个项目的/WebContent/WEB/lib文件夹中添加了所有ActiveMQ依赖war。我在两个wars的context.xml文件中配置了以下资源。context.xml文件放置在/WebContent/META/文件夹中，用于这两个wars。
Context.xml
<Context>
<Resource
name="myConFactory"
auth="Contai
浏览 4提问于2016-10-06得票数 1
在MySql表和Java程序的帮助下实现了一个队列。我想用Apache ActiveMQ实现以下程序，任何建议都是非常感谢的。
表名: XXXXX
Col's : id | Msg | key_id |Status
----------------------------|------
| 1 | Msg1| 1 | 1
| 2 | Msg2| 2 | 1
| 3 | Msg3| 1 | 0
| 4 | Msg4| 1 | 0
| 5 | Msg5
浏览 2提问于2015-03-03得票数 3
1回答
我使用ActiveMQ作为JMS Server，我想发送几秒钟后过期的非持久化消息，因为我不想在消费客户端宕机时排队等待太多消息。(有没有最好的实践？)
问题是如果JMS服务器时间戳与JMS客户端时间戳不同。有没有好的方法来获取JMS服务器的时间戳？或者ActiveMQ 是解决这个问题的“最佳”方法？
浏览 2提问于2013-03-08得票数 1
回答已采纳
1回答
我制作了一个简单的Jms项目，包含两个java文件：MessageSender.java,MessageConsumer.java.one，用于向Activemq:Queue发送消息；另一个用于消费来自Activemq:Queue.Deployed的消息-- Apache Tomcat.following代码中的项目是消费者代码。
ActiveMQConnectionFactory connectionFactory=new ActiveMQConnectionFactory("admin","admin","tcp://localhost:61617
浏览 3提问于2013-09-16得票数 1
使用play Framework2.5 for Java
我想要创建一个应用程序，它使用来自ActiveMQ的数据，从接收到的消息中执行一个hibernate查询到数据库，并存储一个对象用户。我简化了我的使用者类，以便在那里创建一个对象，同时调用持久性。
当我从接收度量的线程(或调用另一个类)调用持久性时，我的问题就出现了。那么EntityManager就不存在了，我也不能创造一个新的，或者坦率地说，我不知道如何让它发挥作用。
package controllers;
import javax.jms.Connection;
import javax.jms.Destination;
imp
浏览 6提问于2016-11-24得票数 0
回答已采纳
1回答
使用以下代码： import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.broker.region.policy.PolicyEntry;
import org.apache.activemq.broker.region.policy.PolicyMap;
import org.apache.activemq.command.ActiveMQDestination;
import java
浏览 12提问于2020-04-03得票数 0
回答已采纳
1回答
我有一个JMS生产者，其中一个使用者是ActiveMQ，请参阅下面的代码：
发送者代码
package activemq;
import javax.jms.ConnectionFactory;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory
浏览 1提问于2015-04-14得票数 2
回答已采纳
在关于JMS的尼斯文章中，Bruce ( "ActiveMQ In Action“的作者)提到：
实现与Spring一起使用的消息侦听器的一个选项是使用javax.jms.MessageListener --它是来自JMS 的标准化接口，但是处理线程取决于您的。
他没有在其他两个选项中谈论线程: Spring、SessionAwareMessageListener和MessageListenerAdapter。
我的问题是:与其他两种方法相比，使用普通javax.jms.MessageListener还需要解决哪些其他线程问题？
我在想，无论我从上面的3中选择什么选项，如果我的
浏览 2提问于2013-05-08得票数 4
回答已采纳
我有一个使用ActiveMQConnectionFactory.createConnection()获取ActiveMQ连接的类。然后，它创建并拥有会话、目的地和监听该目的地的使用者(队列)。
我在消费者上调用接收()或接收(Millis)来从队列中获取我的消息。在某些情况下，我必须终止(中断)调用接收方法的线程。我尝试在那之后立即关闭会话和连接。不幸的是，当我调用close时，我经常得到一个异常，并且相关的"ActiveMQ传输“线程(以及到代理的相关连接)保持活动状态。我得到的例外是
org.myorg.awsiface.communication.MessagingExcepti
浏览 0提问于2011-07-16得票数 5
有没有人能告诉我在Spring中用receiveTimeout = -1定义的DefaultMessageListenerContainer (也就是使用javax.jms.MessageConsumer#receive的阻塞版本)的方法？
实际上，我已经尝试过DMLC的stop()和shutdown()方法，但是使用者线程在接收()调用时被卡住了。
"heartBeatContainer-1" prio=6 tid=0x0304d800 nid=0x1d20 in Object.wait() [0x037ef000]
java.lang.Thread.State: WAITI
浏览 0提问于2013-02-06得票数 1
我试图为一个用于向ActiveMQ发送JMS消息的类编写一个测试。我试图完成的是在被测试的类中获得一个方法，将消息发送到本地主机中的ActiveMQ实例，然后在测试中获取消息并验证它是否正确。
我选择它作为我的代理url：vm://localhost?broker.persistent=true，这意味着将创建一个本地ActiveMQ实例，并将消息存储在一个KahaDB中(该消息也会被创建)。(我尝试使用broker.persistent=false，但是由于所测试的方法有一个关闭连接的finally-clause，所以内存中的消息在我检索之前就丢失了。)
为了检索该消息并验证它，我有以下代码
浏览 3提问于2013-07-26得票数 1
回答已采纳
我正在我的项目中实现Apache ActiveMQ Artemis，该项目连接到Artemis远程服务器。因此，我首先决定与生产者和消费者一起创建一个独立的项目。
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
impor
浏览 1提问于2019-06-10得票数 0
回答已采纳
我已经用ActiveMQ和Spring做了一些测试。我已经将DefaultMessageListenerContainer (DMLC)配置为使用WorkManagerTaskExecutor和CommonJ来管理线程。我希望控制在服务器中运行的线程。
我决定使用DMLC是基于Juergen在Spring论坛上写的一篇文章：
在这篇文章中，他说"DMLC是唯一不将线程管理强加给JMS提供者的侦听器容器，也就是说，不使用/阻止JMS提供程序线程。“所以我认为所有的线程都将由服务器来管理，而不会有ActiveMQ的线程。
但是，在使用JConsole分析服务器线程时，我看到了一些我没想到的
浏览 5提问于2016-01-08得票数 1
回答已采纳
我已经用Java语言创建了ActiveMQ消费者文件。当我尝试连接到ActiveMQ时，它显示： exception in run method::javax.jms.JMSException: Could not create Transport. Reason: java.io.IOException: Transport scheme NOT recognized: [tcp] 当我运行与独立文件相同的消费者文件时，它可以正常工作，但使用Ant构建时，它不能工作。我已经在构建路径中包含了activemq-all.jar。但它仍然不起作用。 连接URL：tcp://localhost:6
浏览 24提问于2019-05-27得票数 0
当我尝试下面的代码时，会得到以下生产者和目的地的错误。我用的是正确的连接工厂吗？
类型会话的方法createQueue(String)未定义
进口org.apache.activemq.ActiveMQConnectionFactory；javax.jms.Connection；进口javax.jms.DeliveryMode；进口javax.jms.Destination；进口javax.jms.ExceptionListener；进口javax.jms.JMSException；进口javax.jms.Message；进口javax.jms.MessageConsumer；进口java
浏览 2提问于2017-10-17得票数 0
我在用ActiveMQ。我的使用者代码是从一个主方法调用的。一旦主类终止，我希望JMSMessageListener已经注册到队列中，并且每当出现关于"TestTopic“的消息时，onMessage就会被调用，这是没有发生的。
//JMS Consumer
public class JMSConsumer {
public void consume() {
String url = "tcp://localhost:61616";
ConnectionFactory factory = new ActiveMQConnectio
浏览 6提问于2014-04-06得票数 2
回答已采纳
1回答
根据相应的JMS ID选择消息的正确语法是什么？
目前我使用的是：
String selector = "JMSMessageID='ID:305:1:5:1:1'";
messageConsumer = session.createConsumer(getRetryQueue(), selector);
上面的语法在模拟代理的测试中起作用。但对于ActiveMQ，消息不会被轮询。
原始代码：
@Override
public Message readMessageFromRetryQueueByJmsId(String jmsId) throws Queuei
浏览 0提问于2013-05-17得票数 4
回答已采纳
我有一个在Java语言中运行的ActiveMQ消费者脚本，在那里我在一个while(true)循环中调用consumer.receive()。 我需要为处理的每条消息实现超时(例如:如果消息处理超过15秒，我必须接收下一条)。 我已将客户端确认模式设置为ACK。 请看我在其中实现了消费的consumeMessage方法。 期望的结果： 15秒后，第一条消息需要被丢弃(即它不应该调用acknowledge())。相反，需要处理下一条消息。 //package consumer;
import org.apache.activemq.ActiveMQConnectionFactory;
imp
浏览 19提问于2019-05-22得票数 0
1回答
所以我有一个简单的JMS应用程序，使用一个主题，由activeMQ提供支持。它起作用了，但只发送了一条消息(即使我在控制台中写了更多的行，因此试图发送更多的东西)。
当我检查ActiveMq的web控制台时，只发送了一条消息(我在ReceiverTopic类中也收到了这条消息)...Why发生了吗？
下面你可以看到我的发送者代码：
package topic;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import javax.jms.Connec
浏览 0提问于2016-08-12得票数 0
回答已采纳
我有一个消费者Java应用程序，连接到一个阿帕奇ActiveMQ服务器。起作用了。但是，如果我停止Apache ActiveMQ服务器，消费者应用程序有一个异常：
java.net.SocketException: Connection reset
我如何处理此异常，例如，我想向支持人员发送一封警报电子邮件。如何检测脱机ActiveMQ服务器。
// Getting JMS connection from the server
ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory
浏览 0提问于2019-03-05得票数 0
我正在遵循一个示例来执行以下操作：“使用JMS后端端点创建一个API --现在让我们在API管理器中创建一个API。您可以在创建API时遵循常规流程。如下所示，请确保在定义资源时启用了‘POST’HTTP动词。
完成此操作后，让我们添加JMS URL作为生产端点。从endpoint type下拉菜单中选择endpoint类型为‘Address endpoint’。生产URL将是实际的JMS端点。ActiveMQ消息队列的JMS URL应该如下所示：
jms:/DataFeed?transport.jms.ConnectionFactoryJNDIName=QueueConnectionFact
浏览 3提问于2016-01-23得票数 0
我想在Pub/Sub中实现project.Basically域，我不是project.Basically开发人员，使用google，我读了这个。我开始实施以下结构。
我将编写为MessageConsumer.java，用于接收来自AMQ的消息并放置在Webserver(Apache )中。
MessageConsumercode：
package PackageName;
import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
浏览 2提问于2013-09-07得票数 5
我刚开始使用activemq。我已经下载了最新的activemq 5.8并运行了服务器。我已经使用以下代码创建了队列并发送示例消息：
// URL of the JMS server. DEFAULT_BROKER_URL will just mean
// that JMS server is on localhost
private static String url = ActiveMQConnection.DEFAULT_BROKER_URL;
// Name of the queue we will be sending messages to
pr
浏览 4提问于2014-02-05得票数 2
我正在尝试将HornetMQ消费者集成到Springboot应用程序中。我看过不同的例子，但它们都指向ActiveMQ实现，这让我有点困惑。我已经用java编写了一个标准的HornetQ消费者。下面是一个代码：
public class HornetQClient {
private String JMS_QUEUE_NAME;
private String MESSAGE_PROPERTY_NAME;
private ClientSessionFactory sf = null;
private static final Logger LOGGER = LoggerFactory.get
浏览 2提问于2018-12-03得票数 0
保持JMS连接/会话/使用者总是处于开放状态是不好的做法吗？
代码草案示例：
// app startup code
ConnectionFactory cf = (ConnectionFactory)jndiContext.lookup(CF_JNDI_NAME);
Connection connection = cf.createConnection(user,pass);
Session session = connection.createSession(true,Session.TRANSACTIONAL);
MessageConsumer consumer = session.c
浏览 0提问于2008-11-07得票数 10
回答已采纳
我有一个发布者正在发布关于主题的消息，我有2个订阅者S1 & S2正在接收这些消息。当我的发布者发送一条消息，并且两个订阅者都在运行时，他们都会收到该消息。但是，当我的订阅服务器没有启动，而我的发布者发送消息时，当订阅服务器出现时，它们就不会收到消息。我的订阅服务器如何接收未运行的消息？
注意:我正在使用Spring。
MessageProducer.java
@RestController
@RequestMapping("/rest/produce")
public class MessageProducer {
private static final L
浏览 0提问于2019-01-20得票数 0
回答已采纳
根据JMS规范，发送时不必指定消息ID。
当我通过JMSProducer#send()发送消息或通过hawt.io控制台创建消息时，我可以看到消息ID被设置为由Artemis生成的内部序列号。
但是，当我使用MessageConsumer#receive()或MessageListener#onMessage()接收Message时，Message#getJMSMessageID()总是返回null。
使用非空JMS消息ID接收消息的唯一方法是从不同(IBM)消息队列中读取消息，并在发送之前将其所有属性复制到Artemis消息中。
我已经在AMQ7.3.0.GA和Apache ActiveMQ
浏览 1提问于2019-06-17得票数 1
回答已采纳
1回答
我正在开发JMS应用程序，现在我想添加支持代理重启功能。我有动态主题，我应该在我的连接恢复后重新创建它们。此外，我应该有一个可能性，知道何时代理停机，当它回来。因此，我尝试使用ActiveMQ故障转移协议来实现此功能。我实现了TransportListener，并在"transportInterrupted“方法中调用了完全断开连接，如下所示
public void disconnect() throws JMSException {
System.out.println("!!!!!!!DISCONNECTING!!!!!!!!");
consum
浏览 4提问于2013-01-05得票数 1
回答已采纳
我有两个关于ActiveMQ故障转移协议的问题。
问题1：当我在嵌套中使用下面的url时，它不会连接到ActiveMQ。
failover:(tcp://192.168.1.111:61616)?nested.jms.useAsyncSend=true&initialReconnectDelay=1000&maxReconnectAttempts=-1
问题2：下面的url运行良好。它还在第一次重新启动时重新连接到ActiveMQ，但是当我第二次关闭ActiveMQ时，Java程序就终止了，没有任何例外。
failover:(tcp://192.168.1.111:61616)
浏览 0提问于2016-04-30得票数 1
2回答
我试图遵循，但是当我将这个类复制到我的项目中时，我运行它失败了。
我不知道我的导入应该是什么样子，因为eclipse建议了很多选项。我试过了
import javax.jms.Connection;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Session;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activem
浏览 0提问于2012-08-06得票数 1
回答已采纳
这是的后续行动.
我的代码可以启动连接、会话等，但是消息不会被消耗。我在日志中没有看到任何例外。
此测试将复制问题：
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.naming.Context
浏览 9提问于2022-09-07得票数 0
回答已采纳
1回答
我创建了一个独立的Java应用程序，它充当一个使用者，用于检索/侦听ActiveMQ队列中的消息。为了达到高可用性的目的，计划在不同的机器上运行这两个实例。
困扰我的是Connection、Session、MessageConsumer和Transaction (Hibernate)的用法。我不想每次在队列中找到消息时打开一个新的Connection、Session、MessageConsumer，因为队列中每秒至少有一条消息，而仅仅打开/关闭资源就不是很有效了(对吗？)关于关闭Transaction对象，可以吗？还是应该在应用程序运行时保持事务打开？
import java.util.Dat
浏览 0提问于2015-07-06得票数 6
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
