@@ -87,7 +87,7 @@ |
||
| 87 | 87 | * |
| 88 | 88 | * @param string $queue |
| 89 | 89 | * |
| 90 | - * @return \Illuminate\Contracts\Queue\Job|null |
|
| 90 | + * @return null|RabbitMqJob |
|
| 91 | 91 | */ |
| 92 | 92 | public function pop($queue = null) |
| 93 | 93 | { |
@@ -15,7 +15,7 @@ discard block |
||
| 15 | 15 | public function register() |
| 16 | 16 | { |
| 17 | 17 | $rabbitMqConfig = $this->app['config']['queue.connections.rabbitmq']; |
| 18 | - $this->app->singleton(Connection::class, function (Application $app) use ($rabbitMqConfig) { |
|
| 18 | + $this->app->singleton(Connection::class, function(Application $app) use ($rabbitMqConfig) { |
|
| 19 | 19 | $params = new ConnectionParameters( |
| 20 | 20 | $rabbitMqConfig['host'], |
| 21 | 21 | $rabbitMqConfig['port'], |
@@ -34,18 +34,18 @@ discard block |
||
| 34 | 34 | return new Connection($params); |
| 35 | 35 | }); |
| 36 | 36 | |
| 37 | - $this->app->singleton(Consumer::class, function (Application $app) { |
|
| 37 | + $this->app->singleton(Consumer::class, function(Application $app) { |
|
| 38 | 38 | return new Consumer($app[Connection::class]); |
| 39 | 39 | }); |
| 40 | 40 | |
| 41 | - $this->app->singleton(Producer::class, function (Application $app) { |
|
| 41 | + $this->app->singleton(Producer::class, function(Application $app) { |
|
| 42 | 42 | return new Producer($app[Connection::class]); |
| 43 | 43 | }); |
| 44 | 44 | |
| 45 | 45 | /** @var QueueManager $queueManager */ |
| 46 | 46 | $queueManager = $this->app['queue']; |
| 47 | 47 | |
| 48 | - $queueManager->addConnector('rabbitmq', function () { |
|
| 48 | + $queueManager->addConnector('rabbitmq', function() { |
|
| 49 | 49 | return new RabbitMQConnector($this->app[Consumer::class], $this->app[Producer::class], $this->app['config']); |
| 50 | 50 | }); |
| 51 | 51 | } |