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