@@ -79,11 +79,11 @@ |
||
| 79 | 79 | ->setConsumerTag($this->consumerTag) |
| 80 | 80 | ->setAutoAck($this->autoAsk) |
| 81 | 81 | ->setRouteKey($this->routeKey) |
| 82 | - ->consume(function ($message) { |
|
| 82 | + ->consume(function($message) { |
|
| 83 | 83 | /** @var Message $message */ |
| 84 | 84 | return static::processMessage($message); |
| 85 | 85 | }); |
| 86 | - } catch (InvalidArgumentException|ErrorException|Exception $exception) { |
|
| 86 | + } catch (InvalidArgumentException | ErrorException | Exception $exception) { |
|
| 87 | 87 | Log::error('AMQPMessage consume error:' . $exception->getMessage()); |
| 88 | 88 | } |
| 89 | 89 | } |