Merge pull request #11 from AltThree/queue-flush

Flush segment on each queue loop
AltThree · Mar 3, 2018 · ed0d71c · ed0d71c
2 parents c9f60ba + 96ec3e8
commit ed0d71c
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/src/SegmentServiceProvider.php b/src/SegmentServiceProvider.php
@@ -37,6 +37,8 @@ public function boot()
         if ($writeKey = $this->app->config->get('segment.write_key')) {
             Segment::init($writeKey, (array) $this->app->config->get('segment.init_options'));
         }
+
+        $this->setupQueue();
     }
 
     /**
@@ -57,6 +59,18 @@ protected function setupConfig()
         $this->mergeConfigFrom($source, 'segment');
     }
 
+    /**
+     * Setup the queue.
+     *
+     * @return void
+     */
+    protected function setupQueue()
+    {
+        $this->app->queue->looping(function () {
+            Segment::flush();
+        });
+    }
+
     /**
      * Register the service provider.
      *