[client] Add ability to hard code the queue name.

- Move null transport to its own package

Author: makasim

DependencyInjection/Compiler/BuildQueueMetaRegistryPass.php

@@ -28,6 +28,10 @@ public function process(ContainerBuilder $container)
 
             foreach ($subscriptions as $subscription) {
                 $configs[$subscription['queueName']]['processors'][] = $subscription['processorName'];
+
+                if ($subscription['queueNameHardcoded']) {
+                    $configs[$subscription['queueName']]['transportName'] = $subscription['queueName'];
+                }
             }
         }
 

DependencyInjection/Compiler/ExtractProcessorTagSubscriptionsTrait.php

@@ -38,6 +38,7 @@ protected function extractSubscriptions(ContainerBuilder $container, $processorS
         $subscriptionPrototype = [
             'topicName' => null,
             'queueName' => null,
+            'queueNameHardcoded' => false,
             'processorName' => null,
         ];
 
@@ -48,6 +49,7 @@ protected function extractSubscriptions(ContainerBuilder $container, $processorS
                     $data[] = [
                         'topicName' => $params,
                         'queueName' => $defaultQueueName,
+                        'queueNameHardcoded' => false,
                         'processorName' => $processorServiceId,
                     ];
                 } elseif (is_array($params)) {
@@ -56,6 +58,7 @@ protected function extractSubscriptions(ContainerBuilder $container, $processorS
                     $data[] = [
                         'topicName' => $topicName,
                         'queueName' => $resolve($params['queueName']) ?: $defaultQueueName,
+                        'queueNameHardcoded' => $resolve($params['queueNameHardcoded']),
                         'processorName' => $resolve($params['processorName']) ?: $processorServiceId,
                     ];
                 } else {
@@ -76,6 +79,7 @@ protected function extractSubscriptions(ContainerBuilder $container, $processorS
                 $data[] = [
                     'topicName' => $resolve($tagAttribute['topicName']),
                     'queueName' => $resolve($tagAttribute['queueName']) ?: $defaultQueueName,
+                    'queueNameHardcoded' => $resolve($tagAttribute['queueNameHardcoded']),
                     'processorName' => $resolve($tagAttribute['processorName']) ?: $processorServiceId,
                 ];
             }

EnqueueBundle.php

@@ -21,7 +21,7 @@
 use Enqueue\Stomp\Symfony\RabbitMqStompTransportFactory;
 use Enqueue\Stomp\Symfony\StompTransportFactory;
 use Enqueue\Symfony\DefaultTransportFactory;
-use Enqueue\Symfony\NullTransportFactory;
+use Enqueue\Null\Symfony\NullTransportFactory;
 use Symfony\Component\DependencyInjection\ContainerBuilder;
 use Symfony\Component\HttpKernel\Bundle\Bundle;
 

Tests/Functional/QueuesCommandTest.php

@@ -17,7 +17,7 @@ public function testCouldBeGetFromContainerAsService()
         $this->assertInstanceOf(QueuesCommand::class, $command);
     }
 
-    public function testShouldDisplayRegisteredDestionations()
+    public function testShouldDisplayRegisteredQueues()
     {
         $command = $this->container->get('enqueue.client.meta.queues_command');
 

Tests/Unit/DependencyInjection/ConfigurationTest.php

@@ -5,7 +5,7 @@
 use Enqueue\Bundle\DependencyInjection\Configuration;
 use Enqueue\Bundle\Tests\Unit\Mocks\FooTransportFactory;
 use Enqueue\Symfony\DefaultTransportFactory;
-use Enqueue\Symfony\NullTransportFactory;
+use Enqueue\Null\Symfony\NullTransportFactory;
 use Enqueue\Test\ClassExtensionTrait;
 use Symfony\Component\Config\Definition\ConfigurationInterface;
 use Symfony\Component\Config\Definition\Exception\InvalidConfigurationException;

Tests/Unit/DependencyInjection/EnqueueExtensionTest.php

@@ -8,9 +8,9 @@
 use Enqueue\Client\Producer;
 use Enqueue\Client\TraceableProducer;
 use Enqueue\Symfony\DefaultTransportFactory;
-use Enqueue\Symfony\NullTransportFactory;
+use Enqueue\Null\Symfony\NullTransportFactory;
 use Enqueue\Test\ClassExtensionTrait;
-use Enqueue\Transport\Null\NullContext;
+use Enqueue\Null\NullContext;
 use Symfony\Component\DependencyInjection\ContainerBuilder;
 use Symfony\Component\DependencyInjection\Reference;
 use Symfony\Component\HttpKernel\DependencyInjection\Extension;

Tests/Unit/EnqueueBundleTest.php

@@ -17,7 +17,7 @@
 use Enqueue\Stomp\Symfony\RabbitMqStompTransportFactory;
 use Enqueue\Stomp\Symfony\StompTransportFactory;
 use Enqueue\Symfony\DefaultTransportFactory;
-use Enqueue\Symfony\NullTransportFactory;
+use Enqueue\Null\Symfony\NullTransportFactory;
 use Enqueue\Test\ClassExtensionTrait;
 use Symfony\Component\DependencyInjection\ContainerBuilder;
 use Symfony\Component\HttpKernel\Bundle\Bundle;

composer.json

@@ -13,7 +13,8 @@
     "require": {
         "php": ">=5.6",
         "symfony/framework-bundle": "^2.8|^3",
-        "enqueue/enqueue": "^0.3"
+        "enqueue/enqueue": "^0.3",
+        "enqueue/null": "^0.3"
     },
     "require-dev": {
         "phpunit/phpunit": "~5.5",