@@ -135,19 +135,16 @@ |
||
135 | 135 | |
136 | 136 | // Sync |
137 | 137 | $handler = $this->sync ? |
138 | - new SyncConsumerHandler($consumer, $this->driver) : |
|
139 | - new AsyncConsumerHandler($consumer); |
|
138 | + new SyncConsumerHandler($consumer, $this->driver) : new AsyncConsumerHandler($consumer); |
|
140 | 139 | $handler->setLogger($this->logger); |
141 | 140 | |
142 | 141 | // Ack |
143 | 142 | $handler = $this->autoAck ? |
144 | - $handler : |
|
145 | - new AckHandler($handler, $this->driver, $this->requeueOnFailure); |
|
143 | + $handler : new AckHandler($handler, $this->driver, $this->requeueOnFailure); |
|
146 | 144 | |
147 | 145 | // Stop / Continue |
148 | 146 | $handler = $this->stopOnFailure ? |
149 | - new StopOnExceptionHandler($handler) : |
|
150 | - new ContinueOnExceptionHandler($handler); |
|
147 | + new StopOnExceptionHandler($handler) : new ContinueOnExceptionHandler($handler); |
|
151 | 148 | $handler->setLogger($this->logger); |
152 | 149 | |
153 | 150 | return $handler; |