File tree Expand file tree Collapse file tree 4 files changed +5
-1
lines changed
Expand file tree Collapse file tree 4 files changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -128,6 +128,7 @@ public function release($delay = 0)
128128 public function with ($ data )
129129 {
130130 $ this ->data = $ data ;
131+
131132 return $ this ;
132133 }
133134
Original file line number Diff line number Diff line change @@ -142,6 +142,7 @@ public function release($delay = 0)
142142 public function with ($ data )
143143 {
144144 $ this ->data = $ data ;
145+
145146 return $ this ;
146147 }
147148
Original file line number Diff line number Diff line change @@ -61,6 +61,7 @@ public function pushJobToQueue($job)
6161
6262 if ($ this ->db ->errors ()) {
6363 $ this ->errors = $ this ->db ->errors ();
64+
6465 return false ;
6566 }
6667
Original file line number Diff line number Diff line change @@ -20,6 +20,7 @@ class Worker
2020 public function queue ($ queue )
2121 {
2222 $ this ->queue = (new Queue ())->connect ($ queue );
23+
2324 return $ this ;
2425 }
2526
@@ -47,7 +48,7 @@ public function run()
4748 $ jobConfig = json_decode ($ jobData ['config ' ] ?? "{} " , true );
4849
4950 /** @var \Leaf\Job */
50- $ job = (new $ jobData ['class ' ])->fromQueue ($ jobData , $ jobConfig , $ this ->queue );
51+ $ job = (new $ jobData ['class ' ]() )->fromQueue ($ jobData , $ jobConfig , $ this ->queue );
5152
5253 $ job ->handleDelay ();
5354
You can’t perform that action at this time.
0 commit comments