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();