Tenlion/wlcb-system-task
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bug修改。

Browse Source
This commit is contained in:
Renpc-kilig 2022-02-09 17:30:05 +08:00
parent 6b79871fde
commit 248b9bb4af
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/cn/com/tenlion/systemtask/utils/fullsync/FullSyncC0006.java
View File

@ -32,7 +32,7 @@ public class FullSyncC0006 implements ApplicationEventPublisherAware {
public FullSyncC0006() {} public FullSyncC0006() {}
@KafkaListener(topics = "C0002FullSync") @KafkaListener(topics = "C0006FullSync")
public void message(ConsumerRecord<?, ?> record) { public void message(ConsumerRecord<?, ?> record) {
System.out.println("收到全量同步命令"); System.out.println("收到全量同步命令");
JSONObject jsonObject = JSONObject.parseObject(record.value().toString()); JSONObject jsonObject = JSONObject.parseObject(record.value().toString());
@ -60,7 +60,7 @@ public class FullSyncC0006 implements ApplicationEventPublisherAware {
} }
} }
@KafkaListener(topics = "C0002") @KafkaListener(topics = "C0006")
public void messageMsg(ConsumerRecord<?, ?> record) { public void messageMsg(ConsumerRecord<?, ?> record) {
JSONObject jsonObject = JSONObject.parseObject(record.value().toString()); JSONObject jsonObject = JSONObject.parseObject(record.value().toString());
Map<String, Object> params = new HashMap<>(); Map<String, Object> params = new HashMap<>();