Skip to content

Commit 0668001

Browse files
committed
Require origin metadata on messages
1 parent 87d8bc4 commit 0668001

2 files changed

Lines changed: 4 additions & 1 deletion

File tree

src/Utopia/Messaging/Adapter.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ private function recordSend(Message $message, int $recipients, int $delivered):
103103
*/
104104
private function telemetryAttributes(Message $message, array $attributes = []): array
105105
{
106-
if (\method_exists($message, 'getOrigin') && $message->getOrigin() !== null) {
106+
if ($message->getOrigin() !== null) {
107107
$attributes['origin'] = $message->getOrigin();
108108
}
109109

src/Utopia/Messaging/Message.php

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,4 +7,7 @@
77
*/
88
interface Message
99
{
10+
public function setOrigin(?string $origin): self;
11+
12+
public function getOrigin(): ?string;
1013
}

0 commit comments

Comments
 (0)