develop

Author: turboboy88

pkg/mongodb/MongodbConnectionFactory.php

@@ -40,6 +40,8 @@ public function __construct($config = 'mongodb:')
         }
         $config = array_replace([
             'uri' => 'mongodb://127.0.0.1/',
+            'dbname' => 'enqueue',
+            'collection_name' => 'enqueue',
         ], $config);
 
         $this->config = $config;

pkg/mongodb/MongodbDestination.php

@@ -28,6 +28,15 @@ public function getQueueName()
         return $this->destinationName;
     }
 
+    /**
+     * Alias for getQueueName()
+     * {@inheritdoc}
+     */
+    public function getName()
+    {
+        return $this->getQueueName();
+    }
+
     /**
      * {@inheritdoc}
      */

pkg/mongodb/MongodbProducer.php

@@ -83,7 +83,7 @@ public function send(PsrDestination $destination, PsrMessage $message)
             'headers' => $message->getHeaders(),
             'properties' => $message->getProperties(),
             'priority' => $message->getPriority(),
-            'queue' => $destination->getQueueName(),
+            'queue' => $destination->getName(),
             'redelivered' => $message->isRedelivered(),
         ];
 

pkg/mongodb/Tests/MongodbContextTest.php

@@ -81,7 +81,7 @@ public function testShouldCreateQueue()
         $queue = $context->createQueue('queue');
 
         $this->assertInstanceOf(MongodbDestination::class, $queue);
-        $this->assertEquals('queue', $queue->getQueueName());
+        $this->assertEquals('queue', $queue->getName());
     }
 
     public function testShouldCreateProducer()

pkg/mongodb/Tests/MongodbDestinationTest.php

@@ -31,7 +31,7 @@ public function testShouldReturnTopicAndQueuePreviouslySetInConstructor()
     {
         $destination = new MongodbDestination('topic-or-queue-name');
 
-        $this->assertSame('topic-or-queue-name', $destination->getQueueName());
+        $this->assertSame('topic-or-queue-name', $destination->getName());
         $this->assertSame('topic-or-queue-name', $destination->getTopicName());
     }
 }