File tree Expand file tree Collapse file tree 2 files changed +5
-4
lines changed Expand file tree Collapse file tree 2 files changed +5
-4
lines changed Original file line number Diff line number Diff line change 33namespace VladimirYuldashev \LaravelQueueRabbitMQ \Horizon \Listeners ;
44
55use Illuminate \Contracts \Events \Dispatcher ;
6- use Illuminate \Queue \Events \JobFailed as LaravelJobFailed ;
76use Laravel \Horizon \Events \JobFailed as HorizonJobFailed ;
7+ use Illuminate \Queue \Events \JobFailed as LaravelJobFailed ;
88use VladimirYuldashev \LaravelQueueRabbitMQ \Queue \Jobs \RabbitMQJob ;
99
1010class RabbitMQFailedEvent
@@ -35,7 +35,7 @@ public function __construct(Dispatcher $events)
3535 */
3636 public function handle (LaravelJobFailed $ event )
3737 {
38- if (!$ event ->job instanceof RabbitMQJob) {
38+ if (! $ event ->job instanceof RabbitMQJob) {
3939 return ;
4040 }
4141
Original file line number Diff line number Diff line change 66use Interop \Amqp \AmqpContext ;
77use InvalidArgumentException ;
88use Illuminate \Contracts \Queue \Queue ;
9+ use Illuminate \Queue \Events \JobFailed ;
910use Interop \Amqp \AmqpConnectionFactory ;
1011use Enqueue \AmqpTools \DelayStrategyAware ;
1112use Illuminate \Contracts \Events \Dispatcher ;
1516use VladimirYuldashev \LaravelQueueRabbitMQ \Queue \RabbitMQQueue ;
1617use Interop \Amqp \AmqpConnectionFactory as InteropAmqpConnectionFactory ;
1718use Enqueue \AmqpLib \AmqpConnectionFactory as EnqueueAmqpConnectionFactory ;
18- use VladimirYuldashev \LaravelQueueRabbitMQ \Horizon \RabbitMQQueue as HorizonRabbitMQQueue ;
1919use VladimirYuldashev \LaravelQueueRabbitMQ \Horizon \Listeners \RabbitMQFailedEvent ;
20- use Illuminate \ Queue \ Events \ JobFailed ;
20+ use VladimirYuldashev \ LaravelQueueRabbitMQ \ Horizon \ RabbitMQQueue as HorizonRabbitMQQueue ;
2121
2222class RabbitMQConnector implements ConnectorInterface
2323{
@@ -82,6 +82,7 @@ public function connect(array $config): Queue
8282
8383 if ($ worker === 'horizon ' ) {
8484 $ this ->dispatcher ->listen (JobFailed::class, RabbitMQFailedEvent::class);
85+
8586 return new HorizonRabbitMQQueue ($ context , $ config );
8687 }
8788
You can’t perform that action at this time.
0 commit comments