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