parent: 74538caf | 补丁 | 提交 | ignore whitespace
liuxiaolong
2019-05-30 f8c281d054f6788b8c348e0a8aac574b48834c8e 
rm protomsg type
1个文件已修改
6 ■■■■■ 已修改文件
server.go 6 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 
 server.go


@@ -6,8 +6,6 @@


    "strings"


    "time"




    "basic.com/pubsub/protomsg.git"




    "golang.org/x/net/context"




    "nanomsg.org/go-mangos"


@@ -240,6 +238,6 @@


    s.publisher.Publish(s.nodes.ToSlice())


}




func (d *DiscoveryServer) PublishMsg(msg protomsg.PublishMessage){


    d.services.publisher.Publish([]string{string(msg)})


func (d *DiscoveryServer) PublishMsg(msg string){


    d.services.publisher.Publish([]string{msg})


}