@@ -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 | } |