更新消息队列监听器架构2.1

5fe06029 · 段启岩 · 67ad6892 · 5fe06029 · 5fe06029
Commit 5fe06029 authored Feb 10, 2020 by 段启岩
Hide whitespace changes
Inline Side-by-side

Showing with 3 additions and 2 deletions

src/main/java/cn/meteor/beyondclouds/core/queue/consumer/DataItemChangeConsumer.java
+2 -1

src/main/java/cn/meteor/beyondclouds/core/queue/consumer/TopicConsumer.java
+1 -1

No files found.
--- a/src/main/java/cn/meteor/beyondclouds/core/listener/DataItemChangeConsumer.java
+++ b/src/main/java/cn/meteor/beyondclouds/core/listener/DataItemChangeConsumer.java
-package cn.meteor.beyondclouds.core.listener;
+package cn.meteor.beyondclouds.core.queue.consumer;

+import cn.meteor.beyondclouds.core.listener.DataItemChangeListener;
 import cn.meteor.beyondclouds.modules.queue.message.DataItemChangeMessage;
 import cn.meteor.beyondclouds.modules.queue.message.DataItemChangeType;
 import cn.meteor.beyondclouds.util.JsonUtils;

--- a/src/main/java/cn/meteor/beyondclouds/core/listener/TopicConsumer.java
+++ b/src/main/java/cn/meteor/beyondclouds/core/listener/TopicConsumer.java
-package cn.meteor.beyondclouds.core.listener;
+package cn.meteor.beyondclouds.core.queue.consumer;

 import org.apache.kafka.clients.consumer.ConsumerRecord;