@@ -1,4 +1,4 @@ |
||
1 | -<?php declare(strict_types = 1); |
|
1 | +<?php declare(strict_types=1); |
|
2 | 2 | |
3 | 3 | namespace Portiny\RabbitMQ\Command; |
4 | 4 |
@@ -1,4 +1,4 @@ discard block |
||
1 | -<?php declare(strict_types = 1); |
|
1 | +<?php declare(strict_types=1); |
|
2 | 2 | |
3 | 3 | namespace Portiny\RabbitMQ\Exchange; |
4 | 4 | |
@@ -23,7 +23,7 @@ discard block |
||
23 | 23 | /** |
24 | 24 | * @throws BunnyException |
25 | 25 | */ |
26 | - final public function declare(Channel $channel): void |
|
26 | + final public function declare(Channel$channel): void |
|
27 | 27 | { |
28 | 28 | $frame = $channel->exchangeDeclare( |
29 | 29 | $this->getName(), |
@@ -35,7 +35,7 @@ discard block |
||
35 | 35 | false, |
36 | 36 | $this->getArguments() |
37 | 37 | ); |
38 | - if (! $frame instanceof MethodExchangeDeclareOkFrame) { |
|
38 | + if ( ! $frame instanceof MethodExchangeDeclareOkFrame) { |
|
39 | 39 | throw new BunnyException(sprintf('Could not declare exchange "%s".', $this->getName())); |
40 | 40 | } |
41 | 41 | } |
@@ -54,7 +54,7 @@ discard block |
||
54 | 54 | false, |
55 | 55 | $exchangeBind->getArguments() |
56 | 56 | ); |
57 | - if (! $frame instanceof MethodExchangeBindOkFrame) { |
|
57 | + if ( ! $frame instanceof MethodExchangeBindOkFrame) { |
|
58 | 58 | throw new BunnyException( |
59 | 59 | sprintf( |
60 | 60 | 'Could not bind exchange "%s" to "%s" with routing key "%s".', |
@@ -1,4 +1,4 @@ |
||
1 | -<?php declare(strict_types = 1); |
|
1 | +<?php declare(strict_types=1); |
|
2 | 2 | |
3 | 3 | namespace Portiny\RabbitMQ\Exchange; |
4 | 4 |
@@ -1,4 +1,4 @@ discard block |
||
1 | -<?php declare(strict_types = 1); |
|
1 | +<?php declare(strict_types=1); |
|
2 | 2 | |
3 | 3 | namespace Portiny\RabbitMQ\Consumer; |
4 | 4 | |
@@ -35,7 +35,7 @@ discard block |
||
35 | 35 | $channel->qos($this->getPrefetchSize(), $this->getPrefetchCount()); |
36 | 36 | |
37 | 37 | return $channel->consume( |
38 | - function (Message $message, Channel $channel, $client) use ($numberOfMessages): void { |
|
38 | + function(Message $message, Channel $channel, $client) use ($numberOfMessages): void { |
|
39 | 39 | try { |
40 | 40 | $result = $this->process($message); |
41 | 41 | } catch (Throwable $throwable) { |
@@ -1,4 +1,4 @@ |
||
1 | -<?php declare(strict_types = 1); |
|
1 | +<?php declare(strict_types=1); |
|
2 | 2 | |
3 | 3 | namespace Portiny\RabbitMQ\Queue; |
4 | 4 |
@@ -1,4 +1,4 @@ discard block |
||
1 | -<?php declare(strict_types = 1); |
|
1 | +<?php declare(strict_types=1); |
|
2 | 2 | |
3 | 3 | namespace Portiny\RabbitMQ\Queue; |
4 | 4 | |
@@ -10,7 +10,7 @@ discard block |
||
10 | 10 | abstract class AbstractQueue |
11 | 11 | { |
12 | 12 | |
13 | - final public function declare(Channel $channel): void |
|
13 | + final public function declare(Channel$channel): void |
|
14 | 14 | { |
15 | 15 | $frame = $channel->queueDeclare( |
16 | 16 | $this->getName(), |
@@ -21,7 +21,7 @@ discard block |
||
21 | 21 | false, |
22 | 22 | $this->getArguments() |
23 | 23 | ); |
24 | - if (! $frame instanceof MethodQueueDeclareOkFrame) { |
|
24 | + if ( ! $frame instanceof MethodQueueDeclareOkFrame) { |
|
25 | 25 | throw new BunnyException(sprintf('Could not declare queue "%s".', $this->getName())); |
26 | 26 | } |
27 | 27 | |
@@ -33,7 +33,7 @@ discard block |
||
33 | 33 | false, |
34 | 34 | $queueBind->getArguments() |
35 | 35 | ); |
36 | - if (! $frame instanceof MethodQueueBindOkFrame) { |
|
36 | + if ( ! $frame instanceof MethodQueueBindOkFrame) { |
|
37 | 37 | throw new BunnyException( |
38 | 38 | sprintf( |
39 | 39 | 'Could not bind queue "%s" to "%s" with routing key "%s".', |
@@ -1,4 +1,4 @@ |
||
1 | -<?php declare(strict_types = 1); |
|
1 | +<?php declare(strict_types=1); |
|
2 | 2 | |
3 | 3 | namespace Portiny\RabbitMQ\Tests; |
4 | 4 |
@@ -1,4 +1,4 @@ |
||
1 | -<?php declare(strict_types = 1); |
|
1 | +<?php declare(strict_types=1); |
|
2 | 2 | |
3 | 3 | namespace Portiny\RabbitMQ\Tests\Source; |
4 | 4 |
@@ -1,4 +1,4 @@ |
||
1 | -<?php declare(strict_types = 1); |
|
1 | +<?php declare(strict_types=1); |
|
2 | 2 | |
3 | 3 | namespace Portiny\RabbitMQ\Tests\Exchange; |
4 | 4 |