Commit f19601b

committed

✅ Support laravel-queue-file driver

1 parent 873a7a5 commit f19601bCopy full SHA for f19601b

File tree

+69

-2

lines changed

+69

-2

lines changed

Lines changed: 6 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`# Laravel Queue Driver For Delayed jobs Can be replaced`
`2`	`2`
`3`		-> 暂时仅支持`Database`和`Redis`驱动
	`3`	+> 暂时仅支持`database`、`redis`以及[`file`](https://github.com/al-one/laravel-queue-file)驱动
`4`	`4`
`5`	`5`
`6`	`6`	`## Installing`
`@@ -32,6 +32,11 @@ return [`
`32`	`32`	`'queue' => 'default',`
`33`	`33`	`'retry_after' => 90,`
`34`	`34`	`],`
	`35`	`+ 'replaceable_file' => [`
	`36`	`+ 'driver' => 'replaceable_file', // composer require al-one/laravel-queue-file`
	`37`	`+ //'path' => 'app/queue', // use storage_path() if not start with "/"`
	`38`	`+ //'queue' => 'default',`
	`39`	`+ ],`
`35`	`40`	`],`
`36`	`41`	`];`
`37`	`42`	```

Lines changed: 5 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -10,7 +10,11 @@`
`10`	`10`	`],`
`11`	`11`	`"require": {`
`12`	`12`	`"php": ">=7.1.3",`
`13`		`- "illuminate/queue": "^5.7 \|\| ^6.0"`
	`13`	`+ "illuminate/queue": "^5.7 \|\| ^6.0",`
	`14`	`+ "illuminate/support": "^5.7 \|\| ^6.0"`
	`15`	`+ },`
	`16`	`+ "suggest": {`
	`17`	`+ "al-one/laravel-queue-file": "Required to use replaceable_file driver."`
`14`	`18`	`},`
`15`	`19`	`"autoload": {`
`16`	`20`	`"psr-4": {`

Lines changed: 25 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,25 @@`
	`1`	`+<?php`
	`2`	`+`
	`3`	`+namespace Alone\LaravelQueueReplaceable\Connectors;`
	`4`	`+`
	`5`	`+use Alone\LaravelQueueReplaceable\FileQueue;`
	`6`	`+use Alone\LaravelQueueFile\FileConnector as BaseConnector;`
	`7`	`+`
	`8`	`+class FileConnector extends BaseConnector`
	`9`	`+{`
	`10`	`+`
	`11`	`+ /**`
	`12`	`+ * Establish a queue connection.`
	`13`	`+ *`
	`14`	`+ * @param array $config`
	`15`	`+ * @return \Illuminate\Contracts\Queue\Queue`
	`16`	`+ */`
	`17`	`+ public function connect(array $config)`
	`18`	`+ {`
	`19`	`+ return new FileQueue(`
	`20`	`+ $config['path'] ?? null,`
	`21`	`+ $config['queue'] ?? 'default'`
	`22`	`+ );`
	`23`	`+ }`
	`24`	`+`
	`25`	`+}`

Lines changed: 29 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,29 @@`
	`1`	`+<?php`
	`2`	`+`
	`3`	`+namespace Alone\LaravelQueueReplaceable;`
	`4`	`+`
	`5`	`+use Alone\LaravelQueueFile\FileQueue as BaseQueue;`
	`6`	`+`
	`7`	`+class FileQueue extends BaseQueue`
	`8`	`+{`
	`9`	`+`
	`10`	`+ use QueueReplaceable;`
	`11`	`+`
	`12`	`+ /**`
	`13`	`+ * Push a raw payload onto the queue after a delay.`
	`14`	`+ *`
	`15`	`+ * @param \DateTimeInterface\|\DateInterval\|int $delay`
	`16`	`+ * @param string $payload`
	`17`	`+ * @param string\|null $queue`
	`18`	`+ * @return mixed`
	`19`	`+ */`
	`20`	`+ public function laterRaw($delay,$payload,$queue = null)`
	`21`	`+ {`
	`22`	`+ if($delay !== 0)`
	`23`	`+ {`
	`24`	`+ $this->popOrRelease($queue,$payload,false);`
	`25`	`+ }`
	`26`	`+ return parent::laterRaw($delay,$payload,$queue);`
	`27`	`+ }`
	`28`	`+`
	`29`	`+}`

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -19,6 +19,10 @@ public function boot()`
`19`	`19`	`{`
`20`	`20`	`return new Connectors\RedisConnector($this->app['redis']);`
`21`	`21`	`});`
	`22`	`+ $queue->addConnector('replaceable_file',function()`
	`23`	`+ {`
	`24`	`+ return new Connectors\FileConnector;`
	`25`	`+ });`
`22`	`26`	`}`
`23`	`27`
`24`	`28`	`}`

Comments

(0)