2
2
3
3
namespace Dusterio \AwsWorker \Controllers ;
4
4
5
- use Dusterio \AwsWorker \Exceptions \FailedJobException ;
6
5
use Dusterio \AwsWorker \Exceptions \MalformedRequestException ;
7
6
use Dusterio \AwsWorker \Jobs \AwsJob ;
8
7
use Dusterio \AwsWorker \Wrappers \WorkerInterface ;
13
12
use Illuminate \Contracts \Console \Kernel ;
14
13
use Illuminate \Console \Scheduling \Schedule ;
15
14
use Illuminate \Http \Response ;
16
- use Symfony \Component \Debug \Exception \FatalThrowableError ;
17
- use Throwable ;
18
15
19
16
class WorkerController extends LaravelController
20
17
{
@@ -65,7 +62,6 @@ public function schedule(Container $laravel, Kernel $kernel, Schedule $schedule)
65
62
* @param Container $laravel
66
63
* @param ExceptionHandler $exceptions
67
64
* @return Response
68
- * @throws FailedJobException
69
65
*/
70
66
public function queue (Request $ request , WorkerInterface $ worker , Container $ laravel , ExceptionHandler $ exceptions )
71
67
{
@@ -81,18 +77,12 @@ public function queue(Request $request, WorkerInterface $worker, Container $lara
81
77
]
82
78
]);
83
79
84
- try {
85
- $ worker ->process (
86
- $ request ->header ('X-Aws-Sqsd-Queue ' ), $ job , [
87
- 'maxTries ' => 0 ,
88
- 'delay ' => 0
89
- ]
90
- );
91
- } catch (\Exception $ e ) {
92
- $ exceptions ->report ($ e );
93
- } catch (Throwable $ e ) {
94
- $ exceptions ->report (new FatalThrowableError ($ e ));
95
- }
80
+ $ worker ->process (
81
+ $ request ->header ('X-Aws-Sqsd-Queue ' ), $ job , [
82
+ 'maxTries ' => 0 ,
83
+ 'delay ' => 0
84
+ ]
85
+ );
96
86
97
87
return $ this ->response ([
98
88
'Processed ' . $ job ->getJobId ()
0 commit comments