From 30ddb8de1ca12e4dc31db2a82e36f7429ee2d7c6 Mon Sep 17 00:00:00 2001
From: 龙赣华 <slongertian@gmail.com>
Date: 星期六, 01 六月 2019 17:50:03 +0800
Subject: [PATCH] modify string to []byte
---
server.go | 17 +++++++----------
1 files changed, 7 insertions(+), 10 deletions(-)
diff --git a/server.go b/server.go
index 94c6a24..fcd8207 100644
--- a/server.go
+++ b/server.go
@@ -2,7 +2,6 @@
import (
"log"
- "strings"
"time"
"golang.org/x/net/context"
@@ -59,7 +58,7 @@
ctx context.Context
sock mangos.Socket
- publishCh chan []string
+ publishCh chan []byte
}
func Server(urlServer string, urlPubSub string, opt Options) (*DiscoveryServer, error) {
@@ -155,8 +154,6 @@
d.services.Add(responses)
return
}
- //fmt.Println(" err: ",err.Error())
- //log.Println("DiscoveryServer: Error reading SURVEY responses", err.Error())
} else {
responses.Add(string(msg))
}
@@ -184,14 +181,14 @@
url: url,
sock: sock,
- publishCh: make(chan []string),
+ publishCh: make(chan []byte),
}
go publiser.run()
return publiser, nil
}
-func (p *Publisher) Publish(msg []string) {
+func (p *Publisher) Publish(msg []byte) {
p.publishCh <- msg
}
@@ -202,7 +199,7 @@
close(p.publishCh)
return
case msg := <-p.publishCh:
- err := p.sock.Send([]byte(strings.Join(msg, "|")))
+ err := p.sock.Send(msg)
if err != nil {
log.Println("DiscoveryServer: Error PUBLISHING changes to the socket", err.Error())
}
@@ -233,6 +230,6 @@
//s.publisher.Publish(s.nodes.ToSlice())//publish nodes changed
}
-func (d *DiscoveryServer) PublishMsg(msg string){
- d.services.publisher.Publish([]string{msg})
-}
\ No newline at end of file
+func (d *DiscoveryServer) PublishMsg(msg string) {
+ d.services.publisher.Publish([]byte(msg))
+}
--
Gitblit v1.8.0