@@ -58,7 +58,8 @@ public static function __callStatic($method, $arguments)
5858 public static function write (array $ parameters , $ payload ): bool
5959 {
6060 if (config ('influxdb.queue.enable ' , false ) === true ) {
61- Write::dispatch ($ parameters , $ payload );
61+ Write::dispatch ($ parameters , $ payload )
62+ ->onQueue (config ('influxdb.queue.name ' , 'default ' ));
6263 } else {
6364 return static ::getFacadeRoot ()
6465 ->write ($ parameters , $ payload );
@@ -80,7 +81,8 @@ public static function writePayload(
8081 $ retentionPolicy = null
8182 ): bool {
8283 if (config ('influxdb.queue.enable ' , false ) === true ) {
83- WritePayload::dispatch ($ payload , $ precision , $ retentionPolicy );
84+ WritePayload::dispatch ($ payload , $ precision , $ retentionPolicy )
85+ ->onQueue (config ('influxdb.queue.name ' , 'default ' ));
8486 } else {
8587 return static ::getFacadeRoot ()
8688 ->writePayload ($ payload , $ precision , $ retentionPolicy );
@@ -102,7 +104,8 @@ public static function writePoints(
102104 $ retentionPolicy = null
103105 ): bool {
104106 if (config ('influxdb.queue.enable ' , false ) === true ) {
105- WritePoints::dispatch ($ points , $ precision , $ retentionPolicy );
107+ WritePoints::dispatch ($ points , $ precision , $ retentionPolicy )
108+ ->onQueue (config ('influxdb.queue.name ' , 'default ' ));
106109 } else {
107110 return static ::getFacadeRoot ()
108111 ->writePoints ($ points , $ precision , $ retentionPolicy );
0 commit comments