@@ -145,17 +145,17 @@ |
||
| 145 | 145 | do { |
| 146 | 146 | try { |
| 147 | 147 | $failed = false; |
| 148 | - fwrite($this->logOutput, 'start Queue::forceReconnect() - trying connect...' . PHP_EOL); |
|
| 148 | + fwrite($this->logOutput, 'start Queue::forceReconnect() - trying connect...'.PHP_EOL); |
|
| 149 | 149 | $this->connection = $this->getConnectionManager()->getConnection($this->connectionName); |
| 150 | 150 | $this->channel = $this->getConnection()->channel(); |
| 151 | 151 | $this->createQueue(); |
| 152 | 152 | } catch (\Exception $e) { |
| 153 | 153 | $failed = true; |
| 154 | 154 | sleep(3); |
| 155 | - fwrite($this->errOutput, 'failed Queue::forceReconnect() - ' . $e->getMessage() . PHP_EOL); |
|
| 155 | + fwrite($this->errOutput, 'failed Queue::forceReconnect() - '.$e->getMessage().PHP_EOL); |
|
| 156 | 156 | } |
| 157 | 157 | } while ($failed); |
| 158 | - fwrite($this->logOutput, 'Queue::forceReconnect() - connected!' . PHP_EOL); |
|
| 158 | + fwrite($this->logOutput, 'Queue::forceReconnect() - connected!'.PHP_EOL); |
|
| 159 | 159 | |
| 160 | 160 | return $this->channel; |
| 161 | 161 | } |