@@ -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 | } |