Merge pull request #32 from joblocal/bugfix/fix-handler-for-messages-…

…triggering-jobs-directly

fix cron job not triggering command

src/Queue/SqsSnsQueue.php

@@ -47,7 +47,7 @@ public function pop($queue = null)
         ]);
 
         if (is_array($response['Messages']) && count($response['Messages']) > 0) {
-            if ($this->routeExists($response['Messages'][0])) {
+            if ($this->routeExists($response['Messages'][0]) || $this->classExists($response['Messages'][0])) {
                 return new SqsSnsJob(
                     $this->container,
                     $this->sqs,
@@ -74,4 +74,18 @@ protected function routeExists(array $message)
 
         return isset($body['Subject']) && array_key_exists($body['Subject'], $this->routes);
     }
+
+    /**
+     * Check if the job class
+     * you're trying to trigger exists.
+     *
+     * @param array $message
+     * @return bool
+     */
+    protected function classExists(array $message)
+    {
+        $body = json_decode($message['Body'], true);
+
+        return isset($body['data']['comandName']) && class_exists($body['data']['commandName']);
+    }
 }