Merge pull request #30 from daniellienert/bugfix/no-serialization

BUGFIX: (Un)serializiation is not needed when using VariableFrontend

Closes: #28

Author: kitsunet

Classes/Command/JobCommandController.php

@@ -154,7 +154,7 @@ public function executeCommand($queue, $messageCacheIdentifier)
         }
 
         /** @var Message $message */
-        $message = unserialize($this->messageCache->get($messageCacheIdentifier));
+        $message = $this->messageCache->get($messageCacheIdentifier);
         $queue = $this->queueManager->getQueue($queue);
         $this->jobManager->executeJobForMessage($queue, $message);
     }

Classes/Job/JobManager.php

@@ -100,7 +100,7 @@ public function waitAndExecute($queueName, $timeout = null)
         try {
             if (isset($queueSettings['executeIsolated']) && $queueSettings['executeIsolated'] === true) {
                 $messageCacheIdentifier = sha1(serialize($message));
-                $this->messageCache->set($messageCacheIdentifier, serialize($message));
+                $this->messageCache->set($messageCacheIdentifier, $message);
                 Scripts::executeCommand('flowpack.jobqueue.common:job:execute', $this->flowSettings, false, [$queue->getName(), $messageCacheIdentifier]);
                 $this->messageCache->remove($messageCacheIdentifier);
             } else {

Classes/Queue/FakeQueue.php

@@ -85,7 +85,7 @@ public function submit($payload, array $options = [])
         $message = new Message($messageId, $payload);
 
         $messageCacheIdentifier = sha1(serialize($message));
-        $this->messageCache->set($messageCacheIdentifier, serialize($message));
+        $this->messageCache->set($messageCacheIdentifier, $message);
 
         if ($this->async) {
             Scripts::executeCommandAsync('flowpack.jobqueue.common:job:execute', $this->flowSettings, [$this->name, $messageCacheIdentifier]);