From 978757c6cd702684d736ddf733f1d718a8c67060 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期四, 01 八月 2019 21:08:44 +0800
Subject: [PATCH] add es cache change
---
discovery/server.go | 13 ++++++-------
1 files changed, 6 insertions(+), 7 deletions(-)
diff --git a/discovery/server.go b/discovery/server.go
index cedfc10..52ac5d3 100644
--- a/discovery/server.go
+++ b/discovery/server.go
@@ -3,10 +3,9 @@
import (
"basic.com/pubsub/protomsg.git"
"basic.com/valib/gopherdiscovery.git"
- "fmt"
+ "github.com/gogo/protobuf/proto"
"time"
"webserver/extend/logger"
- "github.com/gogo/protobuf/proto"
)
const (
@@ -16,7 +15,7 @@
//鍚姩discovery鐨剆erver
var discoveryServer *gopherdiscovery.DiscoveryServer
-var dbChangeChan chan *protomsg.DbChangeMessage
+var dbChangeChan chan *protomsg.EsPersonCacheChange
func StartServer() {
var clients []string
var err error
@@ -34,7 +33,7 @@
logger.Debug("err:",err)
logger.Debug("clients: ",clients)
- dbChangeChan = make(chan *protomsg.DbChangeMessage)
+ dbChangeChan = make(chan *protomsg.EsPersonCacheChange)
for {
select {
@@ -45,14 +44,14 @@
}
//骞挎挱鏁版嵁搴撴敼鍙樼殑msg
-func publishMessage(msg *protomsg.DbChangeMessage) {
+func publishMessage(msg *protomsg.EsPersonCacheChange) {
sendBytes,err := proto.Marshal(msg)
if err ==nil{
discoveryServer.PublishMsg(string(sendBytes))
}
}
-func AddDbMessage(msg *protomsg.DbChangeMessage) {
- fmt.Println("MSG In")
+func AddDbMessage(msg *protomsg.EsPersonCacheChange) {
+ logger.Debug("MSG EsPersonCacheChange In")
dbChangeChan<-msg
}
\ No newline at end of file
--
Gitblit v1.8.0