fix:队列任务执行结束导出监控信息

Author: billpyang

src/Handlers/RequestTerminatedHandler.php

@@ -5,8 +5,7 @@
 namespace Overtrue\LaravelOpenTelemetry\Handlers;
 
 use Laravel\Octane\Events\RequestTerminated;
-use Overtrue\LaravelOpenTelemetry\Facades\Measure;
-use Overtrue\LaravelOpenTelemetry\Facades\Metric;
+use Overtrue\LaravelOpenTelemetry\Support\MeasureDataFlusher;
 
 class RequestTerminatedHandler
 {
@@ -16,7 +15,6 @@ class RequestTerminatedHandler
     public function handle(RequestTerminated $event): void
     {
         // In Octane mode, we need to force flush the tracer provider.
-        Measure::flush();
-        Metric::flush();
+        MeasureDataFlusher::flush();
     }
 }

src/Support/MeasureDataFlusher.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace Overtrue\LaravelOpenTelemetry\Support;
+
+use Overtrue\LaravelOpenTelemetry\Facades\Measure;
+use Overtrue\LaravelOpenTelemetry\Facades\Metric;
+
+class MeasureDataFlusher
+{
+
+    public static function flush(): void
+    {
+        Measure::flush();
+        Metric::flush();
+    }
+}

src/Watchers/QueueWatcher.php

@@ -11,6 +11,7 @@
 use Illuminate\Queue\Events\JobQueued;
 use OpenTelemetry\SemConv\TraceAttributes;
 use Overtrue\LaravelOpenTelemetry\Facades\Measure;
+use Overtrue\LaravelOpenTelemetry\Support\MeasureDataFlusher;
 
 /**
  * Queue Watcher
@@ -76,6 +77,8 @@ public function recordJobProcessed(JobProcessed $event): void
             'messaging.job.class' => $jobClass,
             'messaging.job.status' => 'completed',
         ]);
+
+        MeasureDataFlusher::flush();
     }
 
     public function recordJobFailed(JobFailed $event): void
@@ -87,5 +90,7 @@ public function recordJobFailed(JobFailed $event): void
             'messaging.job.class' => $jobClass,
             'messaging.job.status' => 'failed',
         ]);
+
+        MeasureDataFlusher::flush();
     }
 }