@@ -78,17 +78,17 @@ discard block |
||
| 78 | 78 | private $rabbitMqObjects = []; |
| 79 | 79 | |
| 80 | 80 | /** |
| 81 | - * Maximum connection's retry |
|
| 82 | - **/ |
|
| 81 | + * Maximum connection's retry |
|
| 82 | + **/ |
|
| 83 | 83 | const MAX_RETRY = 10; |
| 84 | 84 | |
| 85 | 85 | /** |
| 86 | - * current retry amount |
|
| 87 | - **/ |
|
| 86 | + * current retry amount |
|
| 87 | + **/ |
|
| 88 | 88 | private static $retry = 0; |
| 89 | 89 | /** |
| 90 | - * time in seconds to wait between each retry |
|
| 91 | - **/ |
|
| 90 | + * time in seconds to wait between each retry |
|
| 91 | + **/ |
|
| 92 | 92 | const WAIT_TIME = 30; |
| 93 | 93 | |
| 94 | 94 | public function __construct($host, $port, $user, $password) |
@@ -180,9 +180,9 @@ discard block |
||
| 180 | 180 | } |
| 181 | 181 | |
| 182 | 182 | /** |
| 183 | - * Function used to create $this->connection |
|
| 184 | - * handle connection's retry in case of the rabbitmq server is not ready yet |
|
| 185 | - **/ |
|
| 183 | + * Function used to create $this->connection |
|
| 184 | + * handle connection's retry in case of the rabbitmq server is not ready yet |
|
| 185 | + **/ |
|
| 186 | 186 | private function createConnection() |
| 187 | 187 | { |
| 188 | 188 | try { |