Add support for using the /topic prefix instead of /exchange. RabbitMQ needs the /exchange prefix for publishing on an exchange, while ActiveMQ needs the /topic prefix for publishing on a topic

Author: Alessandro Niciforo

pkg/stomp/StompContext.php

@@ -23,15 +23,21 @@ class StompContext implements Context
      */
     private $stomp;
 
+    /**
+     * @var bool
+     */
+    private $useExchangePrefix;
+
     /**
      * @var callable
      */
     private $stompFactory;
 
     /**
      * @param BufferedStompClient|callable $stomp
+     * @param bool $useExchangePrefix
      */
-    public function __construct($stomp)
+    public function __construct($stomp, $useExchangePrefix = true)
     {
         if ($stomp instanceof BufferedStompClient) {
             $this->stomp = $stomp;
@@ -40,6 +46,8 @@ public function __construct($stomp)
         } else {
             throw new \InvalidArgumentException('The stomp argument must be either BufferedStompClient or callable that return BufferedStompClient.');
         }
+
+        $this->useExchangePrefix = $useExchangePrefix;
     }
 
     /**
@@ -84,7 +92,7 @@ public function createTopic(string $name): Topic
     {
         if (0 !== strpos($name, '/')) {
             $destination = new StompDestination();
-            $destination->setType(StompDestination::TYPE_EXCHANGE);
+            $destination->setType($this->useExchangePrefix ? StompDestination::TYPE_EXCHANGE : StompDestination::TYPE_TOPIC);
             $destination->setStompName($name);
 
             return $destination;

pkg/stomp/Tests/StompContextTest.php

@@ -79,7 +79,7 @@ public function testCreateQueueShouldCreateDestinationIfNameIsFullDestinationStr
         $this->assertEquals('/amq/queue/name/routing-key', $destination->getQueueName());
     }
 
-    public function testShouldCreateTopicInstance()
+    public function testShouldCreateTopicInstanceWithExchangePrefix()
     {
         $context = new StompContext($this->createStompClientMock());
 
@@ -91,6 +91,18 @@ public function testShouldCreateTopicInstance()
         $this->assertSame(StompDestination::TYPE_EXCHANGE, $topic->getType());
     }
 
+    public function testShouldCreateTopicInstanceWithTopicPrefix()
+    {
+        $context = new StompContext($this->createStompClientMock(), false);
+
+        $topic = $context->createTopic('the name');
+
+        $this->assertInstanceOf(StompDestination::class, $topic);
+        $this->assertSame('/topic/the name', $topic->getQueueName());
+        $this->assertSame('/topic/the name', $topic->getTopicName());
+        $this->assertSame(StompDestination::TYPE_TOPIC, $topic->getType());
+    }
+
     public function testCreateTopicShouldCreateDestinationIfNameIsFullDestinationString()
     {
         $context = new StompContext($this->createStompClientMock());