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