@@ -47,7 +47,7 @@ |
||
47 | 47 | |
48 | 48 | public function changeText($text) |
49 | 49 | { |
50 | - if(! $this->isConvertibleToString($text)) |
|
50 | + if( ! $this->isConvertibleToString($text)) |
|
51 | 51 | { |
52 | 52 | throw new \LogicException('Body of type Text must be string convertible.'); |
53 | 53 | } |
@@ -36,7 +36,7 @@ discard block |
||
36 | 36 | $this->encodingMode = FORCE_GZIP; |
37 | 37 | $this->logger = new NullLogger(); |
38 | 38 | |
39 | - if(! $bodyFactory instanceof BodyFactory) |
|
39 | + if( ! $bodyFactory instanceof BodyFactory) |
|
40 | 40 | { |
41 | 41 | $bodyFactory = new Standard(); |
42 | 42 | } |
@@ -48,7 +48,7 @@ discard block |
||
48 | 48 | */ |
49 | 49 | public function setCompressionLevel($compressionLevel = -1) |
50 | 50 | { |
51 | - if(! $this->isCompressionLevelValid($compressionLevel)) |
|
51 | + if( ! $this->isCompressionLevelValid($compressionLevel)) |
|
52 | 52 | { |
53 | 53 | $this->logWarning(sprintf( |
54 | 54 | "Invalid compression level (%s)", |
@@ -79,7 +79,7 @@ discard block |
||
79 | 79 | |
80 | 80 | public function setEncodingMode($mode) |
81 | 81 | { |
82 | - if(! is_scalar($mode) || ! in_array($mode, [FORCE_GZIP, FORCE_DEFLATE])) |
|
82 | + if( ! is_scalar($mode) || ! in_array($mode, [FORCE_GZIP, FORCE_DEFLATE])) |
|
83 | 83 | { |
84 | 84 | $this->logWarning(sprintf( |
85 | 85 | "Invalid encoding mode (%s)", |
@@ -12,7 +12,7 @@ |
||
12 | 12 | |
13 | 13 | public function __construct(BodyFactory $bodyFactory = null) |
14 | 14 | { |
15 | - if(! $bodyFactory instanceof BodyFactory) |
|
15 | + if( ! $bodyFactory instanceof BodyFactory) |
|
16 | 16 | { |
17 | 17 | $bodyFactory = new Standard(); |
18 | 18 | } |
@@ -18,7 +18,7 @@ |
||
18 | 18 | { |
19 | 19 | $factory = $this->messageAdapterFactory; |
20 | 20 | |
21 | - if(! $factory instanceof MessageAdapterFactory) |
|
21 | + if( ! $factory instanceof MessageAdapterFactory) |
|
22 | 22 | { |
23 | 23 | $factory = new MessageAdapterFactory(); |
24 | 24 | } |
@@ -20,7 +20,7 @@ discard block |
||
20 | 20 | { |
21 | 21 | $this->changeRoutingKeyPrefix(self::DEFAULT_ROUTING_KEY_PREFIX); |
22 | 22 | |
23 | - if(! $memory instanceof MemoryManagementStrategy) |
|
23 | + if( ! $memory instanceof MemoryManagementStrategy) |
|
24 | 24 | { |
25 | 25 | $memory = new NullMemoryManagementStrategy(); |
26 | 26 | } |
@@ -43,7 +43,7 @@ discard block |
||
43 | 43 | { |
44 | 44 | $streamedContent = $chunkedMessage->getBodyInTransportFormat(); |
45 | 45 | |
46 | - if(! $streamedContent instanceof \Generator) |
|
46 | + if( ! $streamedContent instanceof \Generator) |
|
47 | 47 | { |
48 | 48 | return $this->client->publish($exchangeName, $chunkedMessage); |
49 | 49 | } |
@@ -52,7 +52,7 @@ |
||
52 | 52 | |
53 | 53 | $stream = fopen($this->filepath, 'r'); |
54 | 54 | |
55 | - while(! feof($stream)) |
|
55 | + while( ! feof($stream)) |
|
56 | 56 | { |
57 | 57 | $content = fread($stream, $this->chunkSize->toBytes()); |
58 | 58 | $playhead++; |
@@ -28,7 +28,7 @@ |
||
28 | 28 | { |
29 | 29 | if(! isset($headers[$key])) |
30 | 30 | { |
31 | - throw new \InvalidArgumentException("Missing $key in chunked message metadata"); |
|
31 | + throw new \InvalidArgumentException("missing $key in chunked message metadata"); |
|
32 | 32 | } |
33 | 33 | } |
34 | 34 |
@@ -15,9 +15,9 @@ discard block |
||
15 | 15 | private string |
16 | 16 | $checksum; |
17 | 17 | |
18 | - public function __construct(string|Uuid $uuid, int $size, int $nbChunks, string $checksum) |
|
18 | + public function __construct(string | Uuid $uuid, int $size, int $nbChunks, string $checksum) |
|
19 | 19 | { |
20 | - if(! $uuid instanceof Uuid) |
|
20 | + if( ! $uuid instanceof Uuid) |
|
21 | 21 | { |
22 | 22 | $uuid = new Uuid($uuid); |
23 | 23 | } |
@@ -34,7 +34,7 @@ discard block |
||
34 | 34 | |
35 | 35 | foreach($requiredKeys as $key) |
36 | 36 | { |
37 | - if(! isset($headers[$key])) |
|
37 | + if( ! isset($headers[$key])) |
|
38 | 38 | { |
39 | 39 | throw new \InvalidArgumentException("Missing $key in chunked message metadata"); |
40 | 40 | } |
@@ -22,7 +22,7 @@ |
||
22 | 22 | |
23 | 23 | foreach($requiredKeys as $key) |
24 | 24 | { |
25 | - if(! isset($headers[$key])) |
|
25 | + if( ! isset($headers[$key])) |
|
26 | 26 | { |
27 | 27 | throw new \InvalidArgumentException("Missing $key in chunk metadata"); |
28 | 28 | } |
@@ -24,7 +24,7 @@ |
||
24 | 24 | { |
25 | 25 | if(! isset($headers[$key])) |
26 | 26 | { |
27 | - throw new \InvalidArgumentException("Missing $key in chunk metadata"); |
|
27 | + throw new \InvalidArgumentException("missing $key in chunk metadata"); |
|
28 | 28 | } |
29 | 29 | } |
30 | 30 |
@@ -1,6 +1,6 @@ |
||
1 | 1 | <?php |
2 | 2 | |
3 | -declare(strict_types = 1); |
|
3 | +declare(strict_types=1); |
|
4 | 4 | |
5 | 5 | namespace Puzzle\AMQP\Workers; |
6 | 6 |