@@ -43,7 +43,7 @@ |
||
| 43 | 43 | |
| 44 | 44 | public function changeContent($content): void |
| 45 | 45 | { |
| 46 | - if(! is_array($content)) |
|
| 46 | + if( ! is_array($content)) |
|
| 47 | 47 | { |
| 48 | 48 | $content = array($content); |
| 49 | 49 | } |
@@ -45,7 +45,7 @@ discard block |
||
| 45 | 45 | |
| 46 | 46 | private function ensureIsConnected(): void |
| 47 | 47 | { |
| 48 | - if(! $this->channel instanceof \AMQPChannel) |
|
| 48 | + if( ! $this->channel instanceof \AMQPChannel) |
|
| 49 | 49 | { |
| 50 | 50 | $configuration = new PrefixedConfiguration($this->configuration, 'amqp/broker'); |
| 51 | 51 | |
@@ -144,7 +144,7 @@ discard block |
||
| 144 | 144 | |
| 145 | 145 | $ex = new \AMQPExchange($this->channel); |
| 146 | 146 | |
| 147 | - if(!empty($exchangeName)) |
|
| 147 | + if( ! empty($exchangeName)) |
|
| 148 | 148 | { |
| 149 | 149 | $ex->setName($exchangeName); |
| 150 | 150 | $ex->setType($type); |
@@ -175,6 +175,9 @@ |
||
| 175 | 175 | return $this->headers; |
| 176 | 176 | } |
| 177 | 177 | |
| 178 | + /** |
|
| 179 | + * @param string $value |
|
| 180 | + */ |
|
| 178 | 181 | public function setAttribute(string $attributeName, $value): WritableMessage |
| 179 | 182 | { |
| 180 | 183 | if($attributeName !== 'headers') |
@@ -212,7 +212,8 @@ |
||
| 212 | 212 | |
| 213 | 213 | public function __toString(): string |
| 214 | 214 | { |
| 215 | - try { |
|
| 215 | + try |
|
| 216 | + { |
|
| 216 | 217 | return (string) Json::encode([ |
| 217 | 218 | 'routing_key' => $this->getRoutingKey(), |
| 218 | 219 | 'body' => (string) $this->body, |