Werkspot /
message-queue
| @@ 74-83 (lines=10) @@ | ||
| 71 | } |
|
| 72 | } |
|
| 73 | ||
| 74 | private function getLogMessage(MessageInterface $message): string |
|
| 75 | { |
|
| 76 | return $message->getId() |
|
| 77 | . ', ' . $message->getDestination() |
|
| 78 | . ', ' . $message->getDeliverAt()->format(DateTime::ATOM) |
|
| 79 | . ', ' . $message->getCreatedAt()->format(DateTime::ATOM) |
|
| 80 | . ', ' . $message->getUpdatedAt()->format(DateTime::ATOM) |
|
| 81 | . ', ' . $message->getTries() |
|
| 82 | . ', ' . $message->getPriority(); |
|
| 83 | } |
|
| 84 | ||
| 85 | private function getLogErrorMessage(Throwable $error): string |
|
| 86 | { |
|
| @@ 194-204 (lines=11) @@ | ||
| 191 | return $result; |
|
| 192 | } |
|
| 193 | ||
| 194 | private function getLogMessage(MessageInterface $message): string |
|
| 195 | { |
|
| 196 | return $message->getId() |
|
| 197 | . ', ' . $message->getDestination() |
|
| 198 | . ', ' . $message->getDeliverAt()->format(DateTime::ATOM) |
|
| 199 | . ', ' . $message->getCreatedAt()->format(DateTime::ATOM) |
|
| 200 | . ', ' . $message->getUpdatedAt()->format(DateTime::ATOM) |
|
| 201 | . ', ' . $message->getTries() |
|
| 202 | . ', ' . $message->getPriority() |
|
| 203 | . ', ' . $this->getPayloadDescription($message); |
|
| 204 | } |
|
| 205 | ||
| 206 | private function getPayloadDescription(MessageInterface $message): string |
|
| 207 | { |
|
| @@ 132-142 (lines=11) @@ | ||
| 129 | $this->messageDeliveryService->deliver($this->message); |
|
| 130 | } |
|
| 131 | ||
| 132 | private function getLogMessage(MessageInterface $message): string |
|
| 133 | { |
|
| 134 | return $message->getId() |
|
| 135 | . ', ' . $message->getDestination() |
|
| 136 | . ', ' . $message->getDeliverAt()->format(DateTime::ATOM) |
|
| 137 | . ', ' . $message->getCreatedAt()->format(DateTime::ATOM) |
|
| 138 | . ', ' . $message->getUpdatedAt()->format(DateTime::ATOM) |
|
| 139 | . ', ' . $message->getTries() |
|
| 140 | . ', ' . $message->getPriority() |
|
| 141 | . ', ' . $this->getPayloadDescription($message); |
|
| 142 | } |
|
| 143 | ||
| 144 | private function getPayloadDescription(MessageInterface $message): string |
|
| 145 | { |
|
