为了账号安全,请及时绑定邮箱和手机立即绑定

Activemq队列消费端onMessage监听不到

/ 猿问

Activemq队列消费端onMessage监听不到

qq_JellyChubby_0 2018-07-25 14:13:16
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);
        }
    }
}


查看完整描述

目前暂无任何回答

添加回答

回复

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信