unistack-org/micro-server-grpc
4
0
Fork 2
Code Issues 3 Pull Requests Actions Packages Projects Releases 48 Wiki Activity

only connect broker if there are subscribers

Browse Source
This commit is contained in:
Asim Aslam 2020-01-19 13:45:28 +00:00 committed by Vasiliy Tolstov
parent ab6334fad1
commit 3a1515040f
1 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
grpc.go
View File

@ -752,16 +752,19 @@ func (g *grpcServer) Start() error {
g.opts.Address = ts.Addr().String() g.opts.Address = ts.Addr().String()
g.Unlock() g.Unlock()
// connect to the broker // only connect if we're subscribed
if err := config.Broker.Connect(); err != nil { if len(g.subscribers) > 0 {
return err // connect to the broker
if err := config.Broker.Connect(); err != nil {
return err
}
baddr := config.Broker.Address()
bname := config.Broker.String()
log.Logf("Broker [%s] Connected to %s", bname, baddr)
} }
baddr := config.Broker.Address()
bname := config.Broker.String()
log.Logf("Broker [%s] Connected to %s", bname, baddr)
// announce self to the world // announce self to the world
if err := g.Register(); err != nil { if err := g.Register(); err != nil {
log.Log("Server register error: ", err) log.Log("Server register error: ", err)