File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 2121use Cake \Queue \Job \Message ;
2222use Enqueue \Consumption \Result ;
2323use Error ;
24- use Exception ;
2524use Interop \Queue \Context ;
2625use Interop \Queue \Message as QueueMessage ;
2726use Interop \Queue \Processor as InteropProcessor ;
2827use Psr \Log \LoggerInterface ;
2928use Psr \Log \NullLogger ;
3029use RuntimeException ;
30+ use Throwable ;
3131
3232class Processor implements InteropProcessor
3333{
@@ -80,7 +80,7 @@ public function process(QueueMessage $message, Context $context)
8080
8181 try {
8282 $ response = $ this ->processMessage ($ jobMessage );
83- } catch (Exception $ e ) {
83+ } catch (Throwable $ e ) {
8484 $ this ->logger ->debug (sprintf ('Message encountered exception: %s ' , $ e ->getMessage ()));
8585 $ this ->dispatchEvent ('Processor.message.exception ' , [
8686 'message ' => $ jobMessage ,
You can’t perform that action at this time.
0 commit comments