Commit a3f860d

committed

laravel-queue-replaceable

1 parent eb5b16a commit a3f860dCopy full SHA for a3f860d

File tree

+27

-22

lines changed

+27

-22

lines changed

Lines changed: 20 additions & 9 deletions

Original file line number	Diff line number	Diff line change
`@@ -5,15 +5,12 @@`
`5`	`5`	`trait QueueReplaceable`
`6`	`6`	`{`
`7`	`7`
`8`		`- /**`
`9`		`- * Create a payload string from the given job and data.`
`10`		`- *`
`11`		`- * @param string $job`
`12`		`- * @param mixed $data`
`13`		`- * @param string $queue`
`14`		`- * @return array`
`15`		`- */`
`16`		`- protected function createPayloadArray($job, $data = '', $queue = null)`
	`8`	`+ protected function createPayload($job,$data = '',$queue = null)`
	`9`	`+ {`
	`10`	`+ return parent::createPayload($this->getReplaceableJob($job),$data,$queue);`
	`11`	`+ }`
	`12`	`+`
	`13`	`+ protected function createPayloadArray($job,$data = '',$queue = null)`
`17`	`14`	`{`
`18`	`15`	`return $this->createPayloadArrayReplaceable($job,$data,$queue);`
`19`	`16`	`}`
`@@ -42,4 +39,18 @@ public function createPayloadArrayReplaceable($job,$data = '',$queue = null)`
`42`	`39`	`return $payload;`
`43`	`40`	`}`
`44`	`41`
	`42`	`+ public function getReplaceableJob($job)`
	`43`	`+ {`
	`44`	`+ $replaceableJob = $job;`
	`45`	`+ if(is_object($job))`
	`46`	`+ {`
	`47`	`+ $replaceableJob = clone $job;`
	`48`	`+ if(method_exists($replaceableJob,'delay'))`
	`49`	`+ {`
	`50`	`+ $replaceableJob->delay(null);`
	`51`	`+ }`
	`52`	`+ }`
	`53`	`+ return $replaceableJob;`
	`54`	`+ }`
	`55`	`+`
`45`	`56`	`}`

Lines changed: 7 additions & 13 deletions

Original file line number	Diff line number	Diff line change
`@@ -2,26 +2,20 @@`
`2`	`2`
`3`	`3`	`namespace Alone\LaravelQueueReplaceable;`
`4`	`4`
`5`		`-use Illuminate\Support\Facades\Queue;`
`6`		`-use Illuminate\Support\ServiceProvider as BaseServiceProvider;`
	`5`	`+use Illuminate\Support;`
`7`	`6`
`8`		`-class ServiceProvider extends BaseServiceProvider`
	`7`	`+class ServiceProvider extends Support\ServiceProvider`
`9`	`8`	`{`
`10`	`9`
`11`		`- /**`
`12`		`- * Indicates if loading of the provider is deferred.`
`13`		`- *`
`14`		`- * @var bool`
`15`		`- */`
`16`		`- protected $defer = true;`
`17`		`-`
`18`		`- public function register()`
	`10`	`+ public function boot()`
`19`	`11`	`{`
`20`		`- Queue::extend('replaceable_database',function()`
	`12`	`+ /** @var \Illuminate\Queue\QueueManager $queue */`
	`13`	`+ $queue = $this->app['queue'];`
	`14`	`+ $queue->addConnector('replaceable_database',function()`
`21`	`15`	`{`
`22`	`16`	`return new Connectors\DatabaseConnector($this->app['db']);`
`23`	`17`	`});`
`24`		`- Queue::extend('replaceable_redis',function()`
	`18`	`+ $queue->addConnector('replaceable_redis',function()`
`25`	`19`	`{`
`26`	`20`	`return new Connectors\RedisConnector($this->app['redis']);`
`27`	`21`	`});`

Comments

(0)