From ad418b5905e56aadd7b9c19b625a84ae6a29957f Mon Sep 17 00:00:00 2001 From: Vasiliy Tolstov Date: Thu, 5 Nov 2020 01:56:02 +0300 Subject: [PATCH] small fix Signed-off-by: Vasiliy Tolstov --- grpc.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/grpc.go b/grpc.go index f387c9b..d06cc1f 100644 --- 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))