如何检查，我们已经读MQ

Question

所有信息需要更新下面的代码你的帮助，目前该代码从IBM MQ第一味精，但我的要求是获取直到MQ为空

private JmsTemplate jmsTemplate; 

public JmsTemplate getJmsTemplate() { 
    return jmsTemplate; 
} 

@Autowired 
public void setJmsTemplate(JmsTemplate jmsTemplate) { 
    this.jmsTemplate = jmsTemplate; 
} 

public String onMessage() throws JMSException, IOException {   

    Message source = jmsTemplate.receive("LQ.SCCO4313"); 

    BytesMessage bm = (BytesMessage) source; 

    byte[] byteArr = new byte[(int) bm.getBodyLength()]; 
    bm.readBytes(byteArr); 

    String msg = new String(byteArr, "UTF-8"); 

    logger.info("Message " + msg); 
    logger.info("MESSAGE received from myMessageQueue "); 
    return msg; 

} 

Answer 1

JMS MessageConsumer的receive（）或receiveNoWait（）将在队列中没有消息时返回null。如果有任何内部错误，将会有例外。

因此，您可以在代码中检查source == null。