@@ -91,10 +91,8 @@ public function reject(Message $message, bool $requeue = false): void
91
91
InvalidMessageException::assertMessageInstanceOf ($ message , PheanstalkMessage::class);
92
92
93
93
if (false == $ message ->getJob ()) {
94
- throw new \LogicException (sprintf (
95
- 'The message could not be %s because it does not have job set. ' ,
96
- $ requeue ? 'requeued ' : 'rejected '
97
- ));
94
+ $ state = $ requeue ? 'requeued ' : 'rejected ' ;
95
+ throw new \LogicException (sprintf ('The message could not be %s because it does not have job set. ' , $ state ));
98
96
}
99
97
100
98
if ($ requeue ) {
@@ -111,7 +109,9 @@ private function convertJobToMessage(Job $job): PheanstalkMessage
111
109
$ stats = $ this ->pheanstalk ->statsJob ($ job );
112
110
113
111
$ message = PheanstalkMessage::jsonUnserialize ($ job ->getData ());
114
- $ message ->setRedelivered ($ stats ['reserves ' ] > 1 );
112
+ if (isset ($ stats ['reserves ' ])) {
113
+ $ message ->setRedelivered ($ stats ['reserves ' ] > 1 );
114
+ }
115
115
$ message ->setJob ($ job );
116
116
117
117
return $ message ;
0 commit comments