如何使用消息的N多一個消費者在ActiveMQ中

Question

以下是我的消費：

public static void main(String[] args) throws JMSException { 
     // Getting JMS connection from the server 
     ConnectionFactory connectionFactory 
      = new ActiveMQConnectionFactory(url); 
     Connection connection = connectionFactory.createConnection(); 
     connection.start(); 

     // Creating session for seding messages 
     Session session = connection.createSession(false, 
      Session.AUTO_ACKNOWLEDGE); 

     // Getting the queue 'TESTQUEUE' 
     Destination destination = session.createQueue(subject); 

     // MessageConsumer is used for receiving (consuming) messages 
     MessageConsumer consumer = session.createConsumer(destination); 

     // Here we receive the message. 
     // By default this call is blocking, which means it will wait 
     // for a message to arrive on the queue. 
     Message message = consumer.receive(); 
     System.out.println(message); 


    // There are many types of Message and TextMessage 
     // is just one of them. Producer sent us a TextMessage 
     // so we must cast to it to get access to its .getText() 
     // method. 
     if(message instanceof ObjectMessage){ 
      ObjectMessage objectMessage = (ObjectMessage)message; 
      System.out.println(" Received Message : '"+objectMessage.getObject()+" '"); 
     } 

     connection.close(); 
    } 

有隊列中的10條消息。
Rightnow，每條消費者消費1條消息。我想要10個消息被每個消費者消費。
我應該爲此做些什麼？

Answer 1

隊列的性質是你有一個生產者和一個消費者。你應該爲此使用主題。