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