@@ -64,17 +64,17 @@ |
||
| 64 | 64 | * @throws TimeoutReaderException |
| 65 | 65 | * @throws ReaderException |
| 66 | 66 | */ |
| 67 | - public function read(callable $callback, $timeout=0) |
|
| 67 | + public function read(callable $callback, $timeout = 0) |
|
| 68 | 68 | { |
| 69 | 69 | $this->messageHandler->setCallback($callback); |
| 70 | 70 | |
| 71 | 71 | try { |
| 72 | 72 | $this->consume($timeout); |
| 73 | - } catch(GracefulStopException $e) { |
|
| 73 | + } catch (GracefulStopException $e) { |
|
| 74 | 74 | $this->logger->info("Gracefully stopping the AWS queue reader", ["exception" => $e]); |
| 75 | - } catch(TimeoutReaderException $e) { |
|
| 75 | + } catch (TimeoutReaderException $e) { |
|
| 76 | 76 | throw $e; |
| 77 | - } catch(\Exception $e) { |
|
| 77 | + } catch (\Exception $e) { |
|
| 78 | 78 | throw new ReaderException("Error occurred while reading", 0, $e); |
| 79 | 79 | } |
| 80 | 80 | } |