@@ -35,7 +35,7 @@ |
||
35 | 35 | { |
36 | 36 | $exchangeParts = []; |
37 | 37 | |
38 | - if(! empty($this->exchangesPrefix)) |
|
38 | + if( ! empty($this->exchangesPrefix)) |
|
39 | 39 | { |
40 | 40 | $exchangeParts[] = trim($this->exchangesPrefix); |
41 | 41 | } |
@@ -73,7 +73,7 @@ discard block |
||
73 | 73 | |
74 | 74 | public function setBody($body) |
75 | 75 | { |
76 | - if(! is_array($body)) |
|
76 | + if( ! is_array($body)) |
|
77 | 77 | { |
78 | 78 | $body = array($body); |
79 | 79 | } |
@@ -211,7 +211,7 @@ discard block |
||
211 | 211 | $writableMessage = new static($routingKey); |
212 | 212 | |
213 | 213 | $decodedBody = $readableMessage->getDecodedBody(); |
214 | - if(! is_array($decodedBody)) |
|
214 | + if( ! is_array($decodedBody)) |
|
215 | 215 | { |
216 | 216 | $decodedBody = array($decodedBody); |
217 | 217 | } |
@@ -224,7 +224,7 @@ discard block |
||
224 | 224 | $skippedAttributes = array('timestamp', 'headers', 'app_id', 'routing_key'); |
225 | 225 | foreach($attributes as $attributeName => $value) |
226 | 226 | { |
227 | - if(! in_array($attributeName, $skippedAttributes)) |
|
227 | + if( ! in_array($attributeName, $skippedAttributes)) |
|
228 | 228 | { |
229 | 229 | $writableMessage->setAttribute($attributeName, $value); |
230 | 230 | } |
@@ -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); |