在 ActiveMQ 经典控制台上创建持久订阅是一项简单且有用的任务,可以使消费者从消费队列中暂停消费后继续接收消息。以下是使用 ActiveMQ 经典控制台创建持久订阅的步骤:
以下是使用 ActiveMQ 经典控制台创建持久订阅的示例代码:
import javax.jms.*;
import org.apache.activemq.ActiveMQConnectionFactory;
public class CreateDurableSubscriber {
public static void main(String[] args) throws JMSException {
// Create a ConnectionFactory
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
// Create a Connection
Connection connection = connectionFactory.createConnection();
connection.start();
// Create a Session
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// Create a TopicSubscriber
Topic topic = session.createTopic("example.topic");
TopicSubscriber subscriber = session.createDurableSubscriber(topic, "example.subscription");
// Set up a message listener
subscriber.setMessageListener(new MessageListener() {
@Override
public void onMessage(Message message) {
try {
System.out.println("Received message: " + ((TextMessage)message).getText());
} catch (JMSException e) {
e.printStackTrace();
}
}
});
}
}
此代码将创建一个名为“example.subscription”的持久订阅,订阅名为“example.topic”的主题。订阅将等待消息到达,并在到达时调用设置的消息监听器。您可以根据自己的需要修改主题和订阅名称。