Merge remote-tracking branch 'origin/master' into sqs-transport

Author: ASKozienko

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

@@ -23,7 +23,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;
 

README.md

@@ -13,6 +13,14 @@ Integrates message queue components to Symfony application.
 * [Questions](https://gitter.im/php-enqueue/Lobby)
 * [Issue Tracker](https://github.com/php-enqueue/enqueue-dev/issues)
 
+## Developed by Forma-Pro
+
+Forma-Pro is a full stack development company which interests also spread to open source development. 
+Being a team of strong professionals we have an aim an ability to help community by developing cutting edge solutions in the areas of e-commerce, docker & microservice oriented architecture where we have accumulated a huge many-years experience. 
+Our main specialization is Symfony framework based solution, but we are always looking to the technologies that allow us to do our job the best way. We are committed to creating solutions that revolutionize the way how things are developed in aspects of architecture & scalability.
+
+If you have any questions and inquires about our open source development, this product particularly or any other matter feel free to contact at [email protected]
+
 ## License
 
 It is released under the [MIT License](LICENSE).

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

@@ -18,7 +18,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",