@@ -45,7 +45,7 @@ discard block |
||
| 45 | 45 | $this->parameters = array_merge($this->parameters, $parameters); |
| 46 | 46 | $this->parameters = $this->parseUrl($this->parameters); |
| 47 | 47 | if (is_array($this->parameters['ssl_context'])) { |
| 48 | - $this->parameters['ssl_context'] = ! empty($this->parameters['ssl_context']) |
|
| 48 | + $this->parameters['ssl_context'] = !empty($this->parameters['ssl_context']) |
|
| 49 | 49 | ? stream_context_create(array('ssl' => $this->parameters['ssl_context'])) |
| 50 | 50 | : null; |
| 51 | 51 | } |
@@ -67,17 +67,17 @@ discard block |
||
| 67 | 67 | return $ref->newInstanceArgs($this->parameters['constructor_args']); |
| 68 | 68 | } |
| 69 | 69 | |
| 70 | - if ($this->class == 'PhpAmqpLib\Connection\AMQPSocketConnection' || is_subclass_of($this->class , 'PhpAmqpLib\Connection\AMQPSocketConnection')) { |
|
| 70 | + if ($this->class == 'PhpAmqpLib\Connection\AMQPSocketConnection' || is_subclass_of($this->class, 'PhpAmqpLib\Connection\AMQPSocketConnection')) { |
|
| 71 | 71 | return new AMQPSocketConnection( |
| 72 | 72 | $this->parameters['host'], |
| 73 | 73 | $this->parameters['port'], |
| 74 | 74 | $this->parameters['user'], |
| 75 | 75 | $this->parameters['password'], |
| 76 | 76 | $this->parameters['vhost'], |
| 77 | - false, // insist |
|
| 77 | + false, // insist |
|
| 78 | 78 | 'AMQPLAIN', // login_method |
| 79 | - null, // login_response |
|
| 80 | - 'en_US', // locale |
|
| 79 | + null, // login_response |
|
| 80 | + 'en_US', // locale |
|
| 81 | 81 | isset($this->parameters['read_timeout']) ? $this->parameters['read_timeout'] : $this->parameters['read_write_timeout'], |
| 82 | 82 | $this->parameters['keepalive'], |
| 83 | 83 | isset($this->parameters['write_timeout']) ? $this->parameters['write_timeout'] : $this->parameters['read_write_timeout'], |
@@ -90,10 +90,10 @@ discard block |
||
| 90 | 90 | $this->parameters['user'], |
| 91 | 91 | $this->parameters['password'], |
| 92 | 92 | $this->parameters['vhost'], |
| 93 | - false, // insist |
|
| 93 | + false, // insist |
|
| 94 | 94 | 'AMQPLAIN', // login_method |
| 95 | - null, // login_response |
|
| 96 | - 'en_US', // locale |
|
| 95 | + null, // login_response |
|
| 96 | + 'en_US', // locale |
|
| 97 | 97 | $this->parameters['connection_timeout'], |
| 98 | 98 | $this->parameters['read_write_timeout'], |
| 99 | 99 | $this->parameters['ssl_context'], |
@@ -127,7 +127,7 @@ discard block |
||
| 127 | 127 | $parameters['host'] = urldecode($url['host']); |
| 128 | 128 | } |
| 129 | 129 | if (isset($url['port'])) { |
| 130 | - $parameters['port'] = (int)$url['port']; |
|
| 130 | + $parameters['port'] = (int) $url['port']; |
|
| 131 | 131 | } |
| 132 | 132 | if (isset($url['user'])) { |
| 133 | 133 | $parameters['user'] = urldecode($url['user']); |