Merge pull request #64 from chadicus/master

Include machineName in message document

.travis.yml

@@ -16,4 +16,4 @@ before_script:
   - yes '' | pecl install -f mongodb
   - composer update $PREFER_LOWEST
 script: ./vendor/bin/phpunit --coverage-clover clover.xml
-after_success: ./vendor/bin/coveralls -v
+after_success: ./vendor/bin/php-coveralls -v

composer.json

@@ -25,11 +25,12 @@
     },
     "require": {
         "php": "^7.0",
-	    "mongodb/mongodb": "^1.1"
+        "ext-mongodb": "*",
+        "mongodb/mongodb": "^1.1"
     },
     "require-dev": {
+        "php-coveralls/php-coveralls": "^2.2",
         "phpunit/phpunit": "^6.5.2",
-        "php-coveralls/php-coveralls": "^1.0",
         "squizlabs/php_codesniffer": "^3.2"
     },
     "autoload": {

src/AbstractQueue.php

@@ -226,6 +226,7 @@ final public function requeue(Message $message)
             'payload' => $message->getPayload(),
             'earliestGet' => $message->getEarliestGet(),
             'priority' => $message->getPriority(),
+            'machineName' => gethostname(),
             'created' => new UTCDateTime(),
         ];
 
@@ -246,6 +247,7 @@ final public function send(Message $message)
             'payload' => $message->getPayload(),
             'earliestGet' => $message->getEarliestGet(),
             'priority' => $message->getPriority(),
+            'machineName' => gethostname(),
             'created' => new UTCDateTime(),
         ];
 

tests/QueueTest.php

@@ -511,6 +511,7 @@ private function assertSingleMessage(Message $expected)
         $this->assertSame((string)$expected->getId(), (string)$actual['_id']);
         $this->assertSame($expected->getPayload(), $actual['payload']);
         $this->assertSame($expected->getPriority(), $actual['priority']);
+        $this->assertSame(gethostname(), $actual['machineName']);
         $this->assertEquals($expected->getEarliestGet(), $actual['earliestGet']);
     }