消息在发送到ActiveMQ之后,可能会被卡在发送队列中,不被消费者接收。这种情况可能有以下原因:
解决方法:
示例代码:
//连接ActiveMQ
String brokerUrl = "tcp://localhost:61616";
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerUrl);
Connection connection = connectionFactory.createConnection();
connection.start();
//创建会话
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
//创建消息
TextMessage message = session.createTextMessage("Hello, ActiveMQ!");
//创建发送者
Destination destination = session.createQueue("test.queue");
MessageProducer producer = session.createProducer(destination);
//发送消息
producer.send(message);
//关闭连接
producer.close();
session.close();
connection.close();