0
ActiveMQ 및 JMS를 사용 중입니다.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();
}
}
}
입니다. 당신은 소모 (및 폐기)이 코드와 메시지를하는
받을조차하지 않고, 내가받지 않는 메시지 –