放掉所有mq消息
This commit is contained in:
@@ -66,11 +66,7 @@ public class NameplateKafkaConsumer {
|
|||||||
log.info("nameplateKafkagetData为空");
|
log.info("nameplateKafkagetData为空");
|
||||||
ack.acknowledge();
|
ack.acknowledge();
|
||||||
return;
|
return;
|
||||||
}
|
}//去掉业务调用
|
||||||
|
|
||||||
tmNameplateCorpus.getData().forEach(nameplate ->
|
|
||||||
tmNameplateCorpusService.processItem(nameplate));
|
|
||||||
|
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
log.error("处理消息失败", e);
|
log.error("处理消息失败", e);
|
||||||
} finally {
|
} finally {
|
||||||
|
|||||||
Reference in New Issue
Block a user