Activemq队列消费端onMessage监听不到

Question

public void onMessage(final Message message) {     if(message instanceof TextMessage) {         try {             TextMessage m = (TextMessage) message;             LOG.info(m.getText());             TaskResultMessage resultMessage = JSON.parseObject(m.getText(), TaskResultMessage.class);             String pathStr = resultMessage.getDataPath();             String fileName = new Path(pathStr).getName();             int index = fileName.indexOf(".");             resultMessage.setSectionTypeId(fileName.substring(0, index));             booster.push(resultMessage.getSectionTypeId(), resultMessage);         } catch (Exception e) {             LOG.error("处理文件异常", e);         }     } }