Skip to content

Commit 8410f03

Browse files
committed
Add machineName to message
1 parent 79761d6 commit 8410f03

File tree

2 files changed

+3
-0
lines changed

2 files changed

+3
-0
lines changed

src/AbstractQueue.php

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -226,6 +226,7 @@ final public function requeue(Message $message)
226226
'payload' => $message->getPayload(),
227227
'earliestGet' => $message->getEarliestGet(),
228228
'priority' => $message->getPriority(),
229+
'machineName' => gethostname(),
229230
'created' => new UTCDateTime(),
230231
];
231232

@@ -246,6 +247,7 @@ final public function send(Message $message)
246247
'payload' => $message->getPayload(),
247248
'earliestGet' => $message->getEarliestGet(),
248249
'priority' => $message->getPriority(),
250+
'machineName' => gethostname(),
249251
'created' => new UTCDateTime(),
250252
];
251253

tests/QueueTest.php

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -511,6 +511,7 @@ private function assertSingleMessage(Message $expected)
511511
$this->assertSame((string)$expected->getId(), (string)$actual['_id']);
512512
$this->assertSame($expected->getPayload(), $actual['payload']);
513513
$this->assertSame($expected->getPriority(), $actual['priority']);
514+
$this->assertSame(gethostname(), $actual['machineName']);
514515
$this->assertEquals($expected->getEarliestGet(), $actual['earliestGet']);
515516
}
516517

0 commit comments

Comments
 (0)