我的应用程序在 Jboss 7.1.1 上运行。我有一个每分钟运行一次的调度程序,需要检查 DLQ 中是否有消息并在数据库中进行一些更新。
我编写了一个消息消费者,它监听预定义的自定义 DLQ。问题是我可以看到自定义 DLQ 中有消息,但consumer.receiveNoWait()
总是返回 null。
下面是创建消费者的代码:
/*this is running fine and creating the consumer*/
public DestinationHandlerImpl(ConnectionFactory connectionFactory,
Destination destination, boolean useTransaction, int delMode,
boolean isProducer) throws JMSException {
connection = connectionFactory.createConnection();
consumer = session.createConsumer(destination);
}
这是使用消息的代码(每分钟运行一次):
/*this always return null, event when there are messages in the queue*/
public <T extends BaseEvent> T recieveMessage()
throws JMSException {
Message message = consumer.receiveNoWait(); // ----> always return null!!!
if (message != null && !(message instanceof ObjectMessage)) {
throw new IllegalArgumentException(
"message object has to be of type ObjectMessage");
}
// Extract the object from the message
return message == null ? null : (T) ((ObjectMessage) message).getObject();
}
我使用了调试模式,我可以看到消费者目标属性设置为正确的队列,那么我做错了什么?