SWR-15367

Author: NekloShcherbyna

composer.json

@@ -34,7 +34,7 @@
     },
     "extra": {
         "branch-alias": {
-            "dev-master": "13.51-dev"
+            "dev-master": "13.52-dev"
         },
         "laravel": {
             "providers": [

src/Queue/Jobs/RabbitMQJobBatchable.php

@@ -0,0 +1,60 @@
+<?php
+
+namespace VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs;
+
+use Illuminate\Contracts\Encryption\Encrypter;
+use Illuminate\Queue\Jobs\JobName;
+use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs\RabbitMQJob as BaseJob;
+
+/**
+ * SQS Job wrapper for RabbitMQ
+ */
+class RabbitMQJobBatchable extends BaseJob
+{
+    /**
+     * Fire the job.
+     *
+     * @return void
+     */
+    public function fire()
+    {
+        $payload = $this->payload();
+
+        [$class, $method] = JobName::parse($payload['job']);
+
+        ($this->instance = $this->resolve($class))->{$method}($this, $payload['data']);
+    }
+
+    /**
+     * Returns target class name
+     *
+     * @return mixed
+     */
+    public function getPayloadClass(): string
+    {
+        $payload = $this->payload();
+
+        return $payload['data']['commandName'];
+    }
+
+    /**
+     * @return object
+     * @throws \RuntimeException
+     */
+    public function getPayloadData(): object
+    {
+        $payload = $this->payload();
+
+        $data = $payload['data'];
+
+        if (str_starts_with($data['command'], 'O:')) {
+            return unserialize($data['command']);
+        }
+
+        if ($this->container->bound(Encrypter::class)) {
+            return unserialize($this->container[Encrypter::class]->decrypt($data['command']));
+        }
+
+        throw new \RuntimeException('Unable to extract job data.');
+    }
+}

src/Queue/Jobs/RabbitMQQueueBatchable.php renamed to src/Queue/RabbitMQQueueBatchable.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs;
+namespace VladimirYuldashev\LaravelQueueRabbitMQ\Queue;
 
 use PhpAmqpLib\Connection\AbstractConnection;
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\RabbitMQQueue as BaseRabbitMQQueue;