From dad83ebc5514a92f7c1ff04ae3fc3b3d088f4e2f Mon Sep 17 00:00:00 2001 From: xiaohanzi Date: Mon, 15 Jun 2020 22:28:54 +0800 Subject: [PATCH] update --- .../com/iformall/mq/impl/AliyunRocketMqConsumer.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/mallinkMQConsumer/src/main/java/com/iformall/mq/impl/AliyunRocketMqConsumer.java b/mallinkMQConsumer/src/main/java/com/iformall/mq/impl/AliyunRocketMqConsumer.java index c30d5f807..f74666ca1 100644 --- a/mallinkMQConsumer/src/main/java/com/iformall/mq/impl/AliyunRocketMqConsumer.java +++ b/mallinkMQConsumer/src/main/java/com/iformall/mq/impl/AliyunRocketMqConsumer.java @@ -60,9 +60,14 @@ public class AliyunRocketMqConsumer extends MqBaseConsumer { Consumer consumer = ONSFactory.createConsumer(properties); consumer.subscribe(topic.getCode(), "*", new MessageListener() { //订阅多个 Tag public Action consume(Message message, ConsumeContext context) { - System.out.println("Receive: " + message); - doMessage(new String(message.getBody())); - return Action.CommitMessage; + try { + System.out.println("Receive: " + message); + doMessage(new String(message.getBody())); + return Action.CommitMessage; + }catch(Exception e) { + log.error("AliyunRocketMqConsumer error:",e); + return Action.ReconsumeLater; + } } }); consumer.start();