File tree Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Original file line number Diff line number Diff line change 22
33namespace LaravelQueueManager \Core ;
44
5+ use Carbon \Carbon ;
56use Illuminate \Console \Scheduling \Schedule ;
67use LaravelQueueManager \Events \ScheduleError ;
78use LaravelQueueManager \Repository \QueueConfigRepository ;
@@ -10,6 +11,8 @@ class Scheduler
1011{
1112 public static function schedule (Schedule $ schedule )
1213 {
14+ /** @var Carbon $dateNow */
15+ $ dateNow = now ();
1316 $ schedulableQueues = QueueConfigRepository::findSchedulables ();
1417
1518 foreach ($ schedulableQueues as $ schedulableQueue ) {
@@ -30,10 +33,10 @@ public static function schedule(Schedule $schedule)
3033 $ params = $ scheduleConfig ->params ;
3134 }
3235
33- $ schedule ->call (function () use ($ schedulableQueue , $ scheduleConfig ) {
36+ $ schedule ->call (function () use ($ schedulableQueue , $ scheduleConfig, $ dateNow ) {
3437 $ className = $ schedulableQueue ->class_name ;
3538
36- $ lockKey = 'QUEUE_LOCK_ ' . $ schedulableQueue ->name . '_ ' . date ('Y-m-d-H-i ' );
39+ $ lockKey = 'QUEUE_LOCK_ ' . $ schedulableQueue ->name . '_ ' . $ dateNow -> format ('Y-m-d-H-i ' );
3740
3841 if (\Cache::has ($ lockKey )) {
3942 return ;
You can’t perform that action at this time.
0 commit comments