From c5aac73ec29f74904b544a722037b39bbb85ab3e Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期四, 07 二月 2019 21:35:35 +0800
Subject: [PATCH] 去serviceCode 改为businessTypeCd 完成
---
OrderService/src/main/java/com/java110/order/kaka/CenserServiceKafkaListener.java | 17 +++++++++--------
1 files changed, 9 insertions(+), 8 deletions(-)
diff --git a/CenterService/src/main/java/com/java110/center/kaka/CenserServiceKafkaListener.java b/OrderService/src/main/java/com/java110/order/kaka/CenserServiceKafkaListener.java
similarity index 60%
rename from CenterService/src/main/java/com/java110/center/kaka/CenserServiceKafkaListener.java
rename to OrderService/src/main/java/com/java110/order/kaka/CenserServiceKafkaListener.java
index f74ce57..2983dc1 100644
--- a/CenterService/src/main/java/com/java110/center/kaka/CenserServiceKafkaListener.java
+++ b/OrderService/src/main/java/com/java110/order/kaka/CenserServiceKafkaListener.java
@@ -1,7 +1,8 @@
-package com.java110.center.kaka;
+package com.java110.order.kaka;
-import com.java110.center.smo.ICenterServiceSMO;
import com.java110.core.base.AppBase;
+import com.java110.order.smo.ICenterServiceSMO;
+import com.java110.order.smo.IOrderServiceSMO;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -18,21 +19,21 @@
@Autowired
- private ICenterServiceSMO centerServiceSMOImpl;
+ private IOrderServiceSMO orderServiceSMOImpl;
@KafkaListener(topics = {"NOTIFY_CENTER_SERVICE"})
public void listen(ConsumerRecord<?, ?> record) {
logger.info("kafka鐨刱ey: " + record.key());
logger.info("kafka鐨剉alue: " + record.value().toString());
- centerServiceSMOImpl.receiveBusinessSystemNotifyMessage(record.value().toString());
+ orderServiceSMOImpl.receiveBusinessSystemNotifyMessage(record.value().toString());
}
- public ICenterServiceSMO getCenterServiceSMOImpl() {
- return centerServiceSMOImpl;
+ public IOrderServiceSMO getOrderServiceSMOImpl() {
+ return orderServiceSMOImpl;
}
- public void setCenterServiceSMOImpl(ICenterServiceSMO centerServiceSMOImpl) {
- this.centerServiceSMOImpl = centerServiceSMOImpl;
+ public void setOrderServiceSMOImpl(IOrderServiceSMO orderServiceSMOImpl) {
+ this.orderServiceSMOImpl = orderServiceSMOImpl;
}
}
--
Gitblit v1.8.0