2017-09-06 10 views
0

ActiveMQ 및 JMS를 사용 중입니다.JMS에서 보류중인 메시지를 수신하지 못함

대기열에 ObjectMessage를 만들었습니다. 나는 그것을받을 수 없다.

대기열에서 이미 사용할 수있는 메시지를 확인하십시오. 메시지를 수신
Object Queue

내 코드는 더 이상 선명도 또는 코드가 필요한 경우, 요청하시기 바랍니다

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(); 
     } 
    } 

} 

입니다. 당신은 소모 (및 폐기)이 코드와 메시지를하는

답변

0

...

messageConsumer.receive(); 
+0

받을조차하지 않고, 내가받지 않는 메시지 –