diff --git a/grpc.go b/grpc.go index 8da88b9..e037a0d 100644 --- a/grpc.go +++ b/grpc.go @@ -621,7 +621,7 @@ func (g *grpcServer) Register() error { g.registered = true - for sb, _ := range g.subscribers { + for sb := range g.subscribers { handler := g.createSubHandler(sb, g.opts) var opts []broker.SubscribeOption if queue := sb.Options().Queue; len(queue) > 0 {