Merge pull request #34 from bendavies/fix-router-topic-name

fix fsdriver router topic name

Author: makasim

Diff for: pkg/fs/Client/FsDriver.php

@@ -173,7 +173,7 @@ public function getConfig()
     private function createRouterTopic()
     {
         return $this->context->createTopic(
-            $this->config->createTransportRouterTopicName($this->config->getRouterTopicName())
+            $this->config->createTransportQueueName($this->config->getRouterTopicName())
         );
     }
 }

Diff for: pkg/fs/Tests/Driver/FsDriverTest.php

@@ -145,6 +145,18 @@ public function testShouldSendMessageToRouter()
     {
         $topic = new FsDestination(TempFile::generate());
         $transportMessage = new FsMessage();
+        $config = $this->createConfigMock();
+
+        $config
+            ->expects($this->once())
+            ->method('getRouterTopicName')
+            ->willReturn('topicName');
+
+        $config
+            ->expects($this->once())
+            ->method('createTransportQueueName')
+            ->with('topicName')
+            ->willReturn('app.topicName');
 
         $producer = $this->createPsrProducerMock();
         $producer
@@ -156,6 +168,7 @@ public function testShouldSendMessageToRouter()
         $context
             ->expects($this->once())
             ->method('createTopic')
+            ->with('app.topicName')
             ->willReturn($topic)
         ;
         $context
@@ -171,7 +184,7 @@ public function testShouldSendMessageToRouter()
 
         $driver = new FsDriver(
             $context,
-            new Config('', '', '', '', '', ''),
+            $config,
             $this->createQueueMetaRegistryMock()
         );
 
@@ -344,4 +357,12 @@ private function createQueueMetaRegistryMock()
     {
         return $this->createMock(QueueMetaRegistry::class);
     }
+
+    /**
+     * @return \PHPUnit_Framework_MockObject_MockObject|Config
+     */
+    private function createConfigMock()
+    {
+        return $this->createMock(Config::class);
+    }
 }