JMSで保留中のメッセージを受信して​​いません

Question

私はActiveMQとJMSを使用しています

私はキューにObjectMessageを作成しました。私はそれを受け取ることができません。

既にキューで利用可能なメッセージを見てください。メッセージを受信するための

私のコードは、任意のより多くの明快さやコードが必要な場合は、お問い合わせください

public class RecieveObjectQueue { 

    public static void main(String[] args) { 
     ApplicationContext ctx = new ClassPathXmlApplicationContext("applicationContext.xml"); 


     try { 
      ConnectionFactory connFactory=(ConnectionFactory) ctx.getBean("connectionFactory"); 

      Connection connection=connFactory.createConnection(); 
      connection.start(); 

     Session session=connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 
     Queue queue = new ActiveMQQueue(SendObjectQueue.OBJECT_QUEUE); 

     MessageConsumer messageConsumer=session.createConsumer(queue); 
     //   messageConsumer.receive(); 

     messageConsumer.setMessageListener(new MessageListener() { 

      @Override 
      public void onMessage(Message message) { 
       ActiveMQObjectMessage activeMsg=(ActiveMQObjectMessage) message; 
       /*if(message instanceof Car){ 
        Car car=(Car) message; 
        System.out.println("Recieved Car=>"+car); 
       }else{ 
        System.out.println("Message is not a car object!!!"); 
       }*/ 

      } 
     }); 
     } catch (JMSException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 
    } 

} 

です。

Answer 1

あなたはこのコードを使用してメッセージを消費（および廃棄）されている...

messageConsumer.receive();