small fix

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-11-05 01:56:02 +03:00
parent 78ef338fe3
commit ad418b5905
1 changed files with 1 additions and 1 deletions
--- a/grpc.go
+++ b/grpc.go
@@ -775,7 +775,7 @@ func (g *grpcServer) Register() error {
 	defer g.Unlock()

 	for sb := range g.subscribers {
-		handler := g.createSubHandler(sb, g.opts)
+		handler := g.createSubHandler(sb, config)
 		var opts []broker.SubscribeOption
 		if queue := sb.Options().Queue; len(queue) > 0 {
 			opts = append(opts, broker.SubscribeGroup(queue))