Merge branch 'v3' into register

2024-12-27 01:25:45 +03:00
parent 75c9d467e7 699358383d
commit 828f211a4e
13 changed files with 120 additions and 302 deletions
--- a/subscriber.go
+++ b/subscriber.go
@@ -174,7 +174,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)
 				}