AC-15524::Make the queue dependency optional in queue_publisher.xml and use the topic if the queue attribute is not available.

Author: Dnyaneshwar S Jambhulkar

app/code/Magento/Stomp/Model/Bulk/Publisher.php

@@ -106,8 +106,9 @@ public function publish($topicName, $data)
 
         $publisher = $this->publisherConfig->getPublisher($topicName);
         $connectionName = $publisher->getConnection()->getName();
-        $queue = $this->queueRepository->get($connectionName, $publisher->getQueue());
-        $bulkQueue = $this->bulkQueueRepository->get($connectionName, $publisher->getQueue());
+        $queueName = $publisher->getQueue() ? $publisher->getQueue(): $topicName;
+        $queue = $this->queueRepository->get($connectionName, $queueName);
+        $bulkQueue = $this->bulkQueueRepository->get($connectionName, $queueName);
         $bulkQueue->push($queue, $topicName, $envelopes);
 
         return null;

app/code/Magento/Stomp/Model/MassPublisher.php

@@ -110,8 +110,9 @@ public function publish($topicName, $data)
 
         $publisher = $this->publisherConfig->getPublisher($topicName);
         $connectionName = $publisher->getConnection()->getName();
-        $queue = $this->queueRepository->get($connectionName, $publisher->getQueue());
-        $bulkQueue = $this->bulkQueueRepository->get($connectionName, $publisher->getQueue());
+        $queueName = $publisher->getQueue() ? $publisher->getQueue(): $topicName;
+        $queue = $this->queueRepository->get($connectionName, $queueName);
+        $bulkQueue = $this->bulkQueueRepository->get($connectionName, $queueName);
         $bulkQueue->push($queue, $topicName, $envelopes);
 
         return null;

app/code/Magento/Stomp/Model/Publisher.php

@@ -94,7 +94,8 @@ public function publish($topicName, $data)
 
         $publisher = $this->publisherConfig->getPublisher($topicName);
         $connectionName = $publisher->getConnection()->getName();
-        $queue = $this->queueRepository->get($connectionName, $publisher->getQueue());
+        $queueName = $publisher->getQueue() ? $publisher->getQueue(): $topicName;
+        $queue = $this->queueRepository->get($connectionName, $queueName);
 
         $queue->push($envelope);
         return null;