|
@@ -28,7 +28,7 @@ public class GraphConsumer implements RocketMQListener<GraphSendDTO>, RocketMQPu
|
|
|
@Override
|
|
|
public void onMessage(GraphSendDTO message) {
|
|
|
log.info("GraphConsumer-接收到队列消息[{}]", message);
|
|
|
- graphApi.send(message);
|
|
|
+ graphApi.send(message).getCheckedData();
|
|
|
log.info("GraphConsumer-消息处理完备[{}]", message);
|
|
|
}
|
|
|
|
|
@@ -37,4 +37,5 @@ public class GraphConsumer implements RocketMQListener<GraphSendDTO>, RocketMQPu
|
|
|
// 不重试
|
|
|
consumer.setMaxReconsumeTimes(0);
|
|
|
}
|
|
|
+
|
|
|
}
|