Fix schedulable

Author: pierophp

src/Core/Scheduler.php

@@ -16,44 +16,51 @@ public static function schedule(Schedule $schedule)
 
             $scheduleConfig = json_decode($schedulableQueue->schedule_config);
 
-            if (!isset($scheduleConfig->method)) {
-                event(new ScheduleError('Method not configured for ' . $schedulableQueue->name, ['command' => 'reread']));
-                continue;
-            }
+            try {
 
-            $method = $scheduleConfig->method;
+                if (!isset($scheduleConfig->method)) {
+                    event(new ScheduleError('ScheduleError - Method not configured for ' . $schedulableQueue->name));
+                    continue;
+                }
 
-            $params = '';
-            if (isset($scheduleConfig->params)) {
-                $params = $scheduleConfig->params;
-            }
+                $method = $scheduleConfig->method;
 
-            $schedule->call(function () use ($schedulableQueue, $scheduleConfig) {
-                $className = $schedulableQueue->class_name;
+                $params = '';
+                if (isset($scheduleConfig->params)) {
+                    $params = $scheduleConfig->params;
+                }
 
-                $lockKey = 'QUEUE_LOCK_' . $schedulableQueue->name . '_' . date('Y-m-d-H-i');
+                $schedule->call(function () use ($schedulableQueue, $scheduleConfig) {
+                    $className = $schedulableQueue->class_name;
 
-                if (\Cache::has($lockKey)) {
-                    return;
-                }
-                
-                $expiresAt = now()->addMinutes(10);
+                    $lockKey = 'QUEUE_LOCK_' . $schedulableQueue->name . '_' . date('Y-m-d-H-i');
 
-                \Cache::put($lockKey, '1', $expiresAt);
-                
-                if ($scheduleConfig->props && is_array($scheduleConfig->props)) {
-                    foreach($scheduleConfig->props as $prop) {
+                    if (\Cache::has($lockKey)) {
+                        return;
+                    }
+                    
+                    $expiresAt = now()->addMinutes(10);
+
+                    \Cache::put($lockKey, '1', $expiresAt);
+                    
+                    if ($scheduleConfig->props && is_array($scheduleConfig->props)) {
+                        foreach($scheduleConfig->props as $prop) {
+                            $job = (new $className());    
+                            $job->setName($schedulableQueue->name);
+                            $job->setProps($prop);
+                            $job->dispatch();
+                        }
+                    } else {
                         $job = (new $className());    
                         $job->setName($schedulableQueue->name);
-                        $job->setProps($prop);
                         $job->dispatch();
                     }
-                } else {
-                    $job = (new $className());    
-                    $job->setName($schedulableQueue->name);
-                    $job->dispatch();
-                }
-            })->$method($params);
+                })->$method($params);
+
+
+            } catch (\Throwable $e) {
+                event(new ScheduleError('Schedule Error - ' . $schedulableQueue->name . ' ' . $e->getMessage()));
+            }
         }
     }