@@ -51,7 +51,7 @@ |
||
| 51 | 51 | * |
| 52 | 52 | * @return AMQPMessage |
| 53 | 53 | */ |
| 54 | - public function getMessage(){ |
|
| 54 | + public function getMessage() { |
|
| 55 | 55 | return $this->message; |
| 56 | 56 | } |
| 57 | 57 | |
@@ -40,11 +40,11 @@ |
||
| 40 | 40 | ->setQueue($this->queue) |
| 41 | 41 | ->setConsumerTag($this->consumerTag) |
| 42 | 42 | ->setAutoAck($this->autoAsk) |
| 43 | - ->consume(function ($message) { |
|
| 43 | + ->consume(function($message) { |
|
| 44 | 44 | /** @var Message $message */ |
| 45 | 45 | return static::processMessage($message); |
| 46 | 46 | }); |
| 47 | - } catch (InvalidArgumentException|ErrorException|Exception $exception) { |
|
| 47 | + } catch (InvalidArgumentException | ErrorException | Exception $exception) { |
|
| 48 | 48 | Log::error('AMQPMessage consume error:' . $exception->getMessage()); |
| 49 | 49 | } |
| 50 | 50 | } |