@@ -298,7 +298,7 @@ discard block |
||
298 | 298 | try { |
299 | 299 | $this->getChannel()->wait(); |
300 | 300 | } catch (AMQPTimeoutException $e) { |
301 | - $this->logger->debug('startConsuming Exception--->'.$e->getMessage()); |
|
301 | + $this->logger->debug('startConsuming Exception--->' . $e->getMessage()); |
|
302 | 302 | usleep(1000); |
303 | 303 | $this->getConnection()->reconnect(); |
304 | 304 | $this->setupChannelConsumer(); |
@@ -417,7 +417,7 @@ discard block |
||
417 | 417 | private function registerShutdownHandler() |
418 | 418 | { |
419 | 419 | $consumer = $this; |
420 | - register_shutdown_function(function () use ($consumer) { |
|
420 | + register_shutdown_function(function() use ($consumer) { |
|
421 | 421 | $consumer->stopConsuming(); |
422 | 422 | }); |
423 | 423 | } |