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))