@@ -30,7 +30,7 @@ discard block |
||
30 | 30 | |
31 | 31 | private function ensureIsConnected() |
32 | 32 | { |
33 | - if(! $this->channel instanceof \AMQPChannel) |
|
33 | + if( ! $this->channel instanceof \AMQPChannel) |
|
34 | 34 | { |
35 | 35 | $configuration = new PrefixedConfiguration($this->configuration, 'amqp/broker'); |
36 | 36 | |
@@ -108,7 +108,7 @@ discard block |
||
108 | 108 | |
109 | 109 | $ex = new \AMQPExchange($this->channel); |
110 | 110 | |
111 | - if(!empty($exchangeName)) |
|
111 | + if( ! empty($exchangeName)) |
|
112 | 112 | { |
113 | 113 | $ex->setName($exchangeName); |
114 | 114 | $ex->setType($type); |
@@ -27,7 +27,7 @@ discard block |
||
27 | 27 | { |
28 | 28 | $retryHeader = $this->getHeader(\Puzzle\AMQP\Consumers\Retry::DEFAULT_RETRY_HEADER); |
29 | 29 | |
30 | - return (!empty($retryHeader) && (int) $retryHeader === $retryOccurence); |
|
30 | + return ( ! empty($retryHeader) && (int) $retryHeader === $retryOccurence); |
|
31 | 31 | } |
32 | 32 | |
33 | 33 | public function applyHooks(MessageHookCollection $messageHookCollection) |
@@ -39,7 +39,7 @@ discard block |
||
39 | 39 | { |
40 | 40 | $headers = $this->getHeaders(); |
41 | 41 | |
42 | - if(! array_key_exists('routing_key', $headers)) |
|
42 | + if( ! array_key_exists('routing_key', $headers)) |
|
43 | 43 | { |
44 | 44 | return null; |
45 | 45 | } |
@@ -44,7 +44,7 @@ |
||
44 | 44 | { |
45 | 45 | $queueNameParts = []; |
46 | 46 | |
47 | - if(! empty($this->queueNamePrefix)) |
|
47 | + if( ! empty($this->queueNamePrefix)) |
|
48 | 48 | { |
49 | 49 | $queueNameParts[] = trim($this->queueNamePrefix); |
50 | 50 | } |