update call Hooks

2024-12-20 21:37:01 +03:00
parent 8ec0a4ef77
commit 82b95f8605
2 changed files with 3 additions and 3 deletions
--- a/subscriber.go
+++ b/subscriber.go
@@ -197,7 +197,7 @@ func (g *Server) createSubHandler(sb *subscriber, opts server.Options) broker.Ha
 				return nil
 			}

-			opts.Hooks.EachNext(func(hook options.Hook) {
+			opts.Hooks.EachPrev(func(hook options.Hook) {
 				if h, ok := hook.(server.HookSubHandler); ok {
 					fn = h(fn)
 				}