ActiveMQ，如何只创建一个消费者？

Question

private void initializeActiveMq() throws JMSException {
            // Create a ConnectionFactory
            ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerUrl);
            // Create a Connection
             connection = connectionFactory.createConnection();
             connection.start();
            // Create a Session
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);


            // Create the destination (Queue)
            Queue queue = session.createQueue(queueName);
             // Create a MessageConsumer from the Session to the Queue
             consumer = session.createConsumer(queue);

             consumer.setMessageListener(this);

    }

那么我如何确保我的队列中只有一个消费者呢？

Answer 1

我也经历过同样的问题。您需要确保您的war在取消部署时有一个优美的关闭过程的概念。

您可以通过一个HTTP Servlet实现init（在这里进行所有初始化）和destroy（在这里进行所有清除）来实现这一点。Destory（）将在取消部署war时被JVM调用。

我使用Spring来定义我所有的bean、ActiveMQ连接、消息消费者和生产者。我的init（）从主xml文件加载Spring应用程序上下文，在本地缓存对它的引用，然后destory（）调用应用程序上下文的close（）。