Added extra listener when horizon is used as worker.

Author: adm-bome

src/Horizon/Listeners/RabbitMQFailedEvent.php

@@ -0,0 +1,46 @@
+<?php
+
+namespace VladimirYuldashev\LaravelQueueRabbitMQ\Horizon\Listeners;
+
+use Illuminate\Contracts\Events\Dispatcher;
+use Illuminate\Queue\Events\JobFailed as LaravelJobFailed;
+use Laravel\Horizon\Events\JobFailed as HorizonJobFailed;
+use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs\RabbitMQJob;
+
+class RabbitMQFailedEvent
+{
+    /**
+     * The event dispatcher implementation.
+     *
+     * @var \Illuminate\Contracts\Events\Dispatcher
+     */
+    public $events;
+
+    /**
+     * Create a new listener instance.
+     *
+     * @param  \Illuminate\Contracts\Events\Dispatcher $events
+     * @return void
+     */
+    public function __construct(Dispatcher $events)
+    {
+        $this->events = $events;
+    }
+
+    /**
+     * Handle the event.
+     *
+     * @param  \Illuminate\Queue\Events\JobFailed $event
+     * @return void
+     */
+    public function handle(LaravelJobFailed $event)
+    {
+        if (!$event->job instanceof RabbitMQJob) {
+            return;
+        }
+
+        $this->events->dispatch((new HorizonJobFailed(
+            $event->exception, $event->job, $event->job->getRawBody()
+        ))->connection($event->connectionName)->queue($event->job->getQueue()));
+    }
+}

src/Queue/Connectors/RabbitMQConnector.php

@@ -16,6 +16,8 @@
 use Interop\Amqp\AmqpConnectionFactory as InteropAmqpConnectionFactory;
 use Enqueue\AmqpLib\AmqpConnectionFactory as EnqueueAmqpConnectionFactory;
 use VladimirYuldashev\LaravelQueueRabbitMQ\Horizon\RabbitMQQueue as HorizonRabbitMQQueue;
+use VladimirYuldashev\LaravelQueueRabbitMQ\Horizon\Listeners\RabbitMQFailedEvent;
+use Illuminate\Queue\Events\JobFailed;
 
 class RabbitMQConnector implements ConnectorInterface
 {
@@ -79,6 +81,7 @@ public function connect(array $config): Queue
         }
 
         if ($worker === 'horizon') {
+            $this->dispatcher->listen(JobFailed::class, RabbitMQFailedEvent::class);
             return new HorizonRabbitMQQueue($context, $config);
         }