diff --git a/pubSub.go b/pubSub.go
index 1011532..1211ddd 100644
--- a/pubSub.go
+++ b/pubSub.go
@@ -53,7 +53,7 @@ func (ps *Pubsub) worker() {
 			func(c func(any), d any) {
 				defer func() { recover() }()
 				c(d)
-			}(cb, job.Data)
+			}(cb, job)
 		}
 	}
 }