rename queue checker name, and add metadata

aozisik · aozisik · commit 0c5196179d0d · 2023-04-06T17:38:01.000+03:00
diff --git a/src/Checks/QueueHealthCheck.php b/src/Checks/QueueHealthCheck.php
@@ -48,7 +48,7 @@ public function failIfJobTakesLongerThan($seconds)
 
     public static function make($queue = 'default')
     {
-        return (new static('queue-check.' . $queue))->queue($queue);
+        return (new static($queue . '_queue'))->queue($queue);
     }
 
     public function queue($queue)
@@ -100,6 +100,11 @@ public function run()
             } elseif ($lastJobDuration >= $this->warnAt) {
                 $result = Result::warn("{$this->queue} wait time is getting longer. (> {$duration})");
             }
+
+            $result->meta([
+                'queue' => $this->queue,
+                'waitTime' => $duration,
+            ]);
         }
 
         $dispatchAgain = $shouldDispatchNewJob && (

Original file line number	Diff line number	Diff line change
`@@ -48,7 +48,7 @@ public function failIfJobTakesLongerThan($seconds)`
`48`	`48`
`49`	`49`	`public static function make($queue = 'default')`
`50`	`50`	`{`
`51`		`- return (new static('queue-check.' . $queue))->queue($queue);`
	`51`	`+ return (new static($queue . '_queue'))->queue($queue);`
`52`	`52`	`}`
`53`	`53`
`54`	`54`	`public function queue($queue)`
`@@ -100,6 +100,11 @@ public function run()`
`100`	`100`	`} elseif ($lastJobDuration >= $this->warnAt) {`
`101`	`101`	`$result = Result::warn("{$this->queue} wait time is getting longer. (> {$duration})");`
`102`	`102`	`}`
	`103`	`+`
	`104`	`+ $result->meta([`
	`105`	`+ 'queue' => $this->queue,`
	`106`	`+ 'waitTime' => $duration,`
	`107`	`+ ]);`
`103`	`108`	`}`
`104`	`109`
`105`	`110`	`$dispatchAgain = $shouldDispatchNewJob && (`