refactor(namespaces): renamed \Null to \NoEffect for future comp…

composer.json

@@ -88,6 +88,7 @@
       "Enqueue\\Gps\\": "pkg/gps/",
       "Enqueue\\JobQueue\\": "pkg/job-queue/",
       "Enqueue\\Mongodb\\": "pkg/mongodb/",
+      "Enqueue\\NoEffect\\": "pkg/noeffect/",
       "Enqueue\\Null\\": "pkg/null/",
       "Enqueue\\Pheanstalk\\": "pkg/pheanstalk/",
       "Enqueue\\RdKafka\\": "pkg/rdkafka/",

docs/transport/null.md

@@ -25,7 +25,7 @@ $ composer require enqueue/null
 
 ```php
 <?php
-use Enqueue\Null\NullConnectionFactory;
+use Enqueue\NoEffect\NullConnectionFactory;
 
 $connectionFactory = new NullConnectionFactory();
 

pkg/amqp-bunny/Tests/AmqpConsumerTest.php

@@ -7,7 +7,7 @@
 use Bunny\Message;
 use Enqueue\AmqpBunny\AmqpConsumer;
 use Enqueue\AmqpBunny\AmqpContext;
-use Enqueue\Null\NullMessage;
+use Enqueue\NoEffect\NullMessage;
 use Enqueue\Test\ClassExtensionTrait;
 use Enqueue\Test\WriteAttributeTrait;
 use Interop\Amqp\Impl\AmqpMessage;

pkg/amqp-bunny/composer.json

@@ -15,7 +15,7 @@
     "require-dev": {
         "phpunit/phpunit": "^9.5",
         "enqueue/test": "0.10.x-dev",
-        "enqueue/null": "0.10.x-dev",
+        "enqueue/noeffect": "0.10.x-dev",
         "queue-interop/queue-spec": "^0.6.2"
     },
     "support": {

pkg/amqp-ext/Tests/AmqpContextTest.php

@@ -6,8 +6,8 @@
 use Enqueue\AmqpExt\AmqpContext;
 use Enqueue\AmqpExt\AmqpProducer;
 use Enqueue\AmqpExt\AmqpSubscriptionConsumer;
-use Enqueue\Null\NullQueue;
-use Enqueue\Null\NullTopic;
+use Enqueue\NoEffect\NullQueue;
+use Enqueue\NoEffect\NullTopic;
 use Enqueue\Test\ClassExtensionTrait;
 use Enqueue\Test\ReadAttributeTrait;
 use Interop\Amqp\Impl\AmqpMessage;
@@ -124,7 +124,7 @@ public function testShouldThrowIfNotAmqpQueueGivenOnCreateConsumerCall()
         $context = new AmqpContext($this->createExtChannelMock());
 
         $this->expectException(InvalidDestinationException::class);
-        $this->expectExceptionMessage('The destination must be an instance of Interop\Amqp\AmqpQueue but got Enqueue\Null\NullQueue.');
+        $this->expectExceptionMessage('The destination must be an instance of Interop\Amqp\AmqpQueue but got Enqueue\NoEffect\NullQueue.');
         $context->createConsumer(new NullQueue('aName'));
     }
 
@@ -133,7 +133,7 @@ public function testShouldThrowIfNotAmqpTopicGivenOnCreateConsumerCall()
         $context = new AmqpContext($this->createExtChannelMock());
 
         $this->expectException(InvalidDestinationException::class);
-        $this->expectExceptionMessage('The destination must be an instance of Interop\Amqp\AmqpTopic but got Enqueue\Null\NullTopic.');
+        $this->expectExceptionMessage('The destination must be an instance of Interop\Amqp\AmqpTopic but got Enqueue\NoEffect\NullTopic.');
         $context->createConsumer(new NullTopic('aName'));
     }
 

pkg/amqp-ext/composer.json

@@ -15,7 +15,7 @@
     "require-dev": {
         "phpunit/phpunit": "^9.5",
         "enqueue/test": "0.10.x-dev",
-        "enqueue/null": "0.10.x-dev",
+        "enqueue/noeffect": "0.10.x-dev",
         "queue-interop/queue-spec": "^0.6.2",
         "empi89/php-amqp-stubs": "*@dev"
     },

pkg/amqp-lib/Tests/AmqpConsumerTest.php

@@ -4,7 +4,7 @@
 
 use Enqueue\AmqpLib\AmqpConsumer;
 use Enqueue\AmqpLib\AmqpContext;
-use Enqueue\Null\NullMessage;
+use Enqueue\NoEffect\NullMessage;
 use Enqueue\Test\ClassExtensionTrait;
 use Enqueue\Test\WriteAttributeTrait;
 use Interop\Amqp\Impl\AmqpMessage;

pkg/amqp-lib/composer.json

@@ -15,7 +15,7 @@
     "require-dev": {
         "phpunit/phpunit": "^9.5",
         "enqueue/test": "0.10.x-dev",
-        "enqueue/null": "0.10.x-dev",
+        "enqueue/noeffect": "0.10.x-dev",
         "queue-interop/queue-spec": "^0.6.2"
     },
     "support": {

pkg/amqp-tools/composer.json

@@ -14,7 +14,7 @@
     "require-dev": {
         "phpunit/phpunit": "^9.5",
         "enqueue/test": "0.10.x-dev",
-        "enqueue/null": "0.10.x-dev"
+        "enqueue/noeffect": "0.10.x-dev"
     },
     "support": {
         "email": "opensource@forma-pro.com",

pkg/async-command/Tests/Functional/UseCasesTest.php

@@ -6,8 +6,8 @@
 use Enqueue\AsyncCommand\RunCommand;
 use Enqueue\AsyncCommand\RunCommandProcessor;
 use Enqueue\Consumption\Result;
-use Enqueue\Null\NullContext;
-use Enqueue\Null\NullMessage;
+use Enqueue\NoEffect\NullContext;
+use Enqueue\NoEffect\NullMessage;
 use Interop\Queue\Message;
 use PHPUnit\Framework\TestCase;
 

pkg/async-command/composer.json

@@ -19,7 +19,7 @@
         "symfony/http-kernel": "^5.1|^6.0",
         "symfony/filesystem": "^5.1|^6.0",
         "symfony/yaml": "^5.1|^6.0",
-        "enqueue/null": "0.10.x-dev",
+        "enqueue/noeffect": "0.10.x-dev",
         "enqueue/fs": "0.10.x-dev",
         "enqueue/test": "0.10.x-dev"
     },

pkg/async-event-dispatcher/Tests/AsyncListenerTest.php

@@ -5,8 +5,8 @@
 use Enqueue\AsyncEventDispatcher\AsyncListener;
 use Enqueue\AsyncEventDispatcher\EventTransformer;
 use Enqueue\AsyncEventDispatcher\Registry;
-use Enqueue\Null\NullMessage;
-use Enqueue\Null\NullQueue;
+use Enqueue\NoEffect\NullMessage;
+use Enqueue\NoEffect\NullQueue;
 use Enqueue\Test\ClassExtensionTrait;
 use Enqueue\Test\ReadAttributeTrait;
 use Interop\Queue\Context;

pkg/async-event-dispatcher/Tests/AsyncProcessorTest.php

@@ -7,8 +7,8 @@
 use Enqueue\AsyncEventDispatcher\EventTransformer;
 use Enqueue\AsyncEventDispatcher\Registry;
 use Enqueue\Consumption\Result;
-use Enqueue\Null\NullContext;
-use Enqueue\Null\NullMessage;
+use Enqueue\NoEffect\NullContext;
+use Enqueue\NoEffect\NullMessage;
 use Enqueue\Test\ClassExtensionTrait;
 use Interop\Queue\Processor;
 use PHPUnit\Framework\MockObject\MockObject;

pkg/async-event-dispatcher/Tests/PhpSerializerEventTransformerTest.php

@@ -4,7 +4,7 @@
 
 use Enqueue\AsyncEventDispatcher\EventTransformer;
 use Enqueue\AsyncEventDispatcher\PhpSerializerEventTransformer;
-use Enqueue\Null\NullMessage;
+use Enqueue\NoEffect\NullMessage;
 use Enqueue\Test\ClassExtensionTrait;
 use Interop\Queue\Context;
 use Interop\Queue\Message;

pkg/async-event-dispatcher/composer.json

@@ -18,7 +18,7 @@
         "symfony/http-kernel": "^5.1|^6.0",
         "symfony/filesystem": "^5.1|^6.0",
         "symfony/yaml": "^5.1|^6.0",
-        "enqueue/null": "0.10.x-dev",
+        "enqueue/noeffect": "0.10.x-dev",
         "enqueue/fs": "0.10.x-dev",
         "enqueue/test": "0.10.x-dev"
     },

pkg/dbal/composer.json

@@ -15,7 +15,7 @@
     "require-dev": {
         "phpunit/phpunit": "^9.5",
         "enqueue/test": "0.10.x-dev",
-        "enqueue/null": "0.10.x-dev",
+        "enqueue/noeffect": "0.10.x-dev",
         "queue-interop/queue-spec": "^0.6.2"
     },
     "support": {

pkg/enqueue-bundle/Tests/Functional/Events/AsyncProcessorTest.php

@@ -7,8 +7,8 @@
 use Enqueue\Bundle\Tests\Functional\App\TestAsyncListener;
 use Enqueue\Bundle\Tests\Functional\App\TestAsyncSubscriber;
 use Enqueue\Bundle\Tests\Functional\WebTestCase;
-use Enqueue\Null\NullContext;
-use Enqueue\Null\NullMessage;
+use Enqueue\NoEffect\NullContext;
+use Enqueue\NoEffect\NullMessage;
 use Enqueue\Util\JSON;
 use Interop\Queue\Processor;
 use Symfony\Component\EventDispatcher\GenericEvent;

pkg/enqueue/Resources.php

@@ -10,7 +10,7 @@
 use Enqueue\Gearman\GearmanConnectionFactory;
 use Enqueue\Gps\GpsConnectionFactory;
 use Enqueue\Mongodb\MongodbConnectionFactory;
-use Enqueue\Null\NullConnectionFactory;
+use Enqueue\NoEffect\NullConnectionFactory;
 use Enqueue\Pheanstalk\PheanstalkConnectionFactory;
 use Enqueue\RdKafka\RdKafkaConnectionFactory;
 use Enqueue\Redis\RedisConnectionFactory;

pkg/enqueue/Tests/Client/ConsumptionExtension/DelayRedeliveredMessageExtensionTest.php

@@ -8,8 +8,8 @@
 use Enqueue\Client\Message;
 use Enqueue\Consumption\Context\MessageReceived;
 use Enqueue\Consumption\Result;
-use Enqueue\Null\NullMessage;
-use Enqueue\Null\NullQueue;
+use Enqueue\NoEffect\NullMessage;
+use Enqueue\NoEffect\NullQueue;
 use Enqueue\Test\TestLogger;
 use Interop\Queue\Consumer;
 use Interop\Queue\Context as InteropContext;

pkg/enqueue/Tests/Client/ConsumptionExtension/ExclusiveCommandExtensionTest.php

@@ -9,8 +9,8 @@
 use Enqueue\Client\RouteCollection;
 use Enqueue\Consumption\Context\MessageReceived;
 use Enqueue\Consumption\MessageReceivedExtensionInterface;
-use Enqueue\Null\NullMessage;
-use Enqueue\Null\NullQueue;
+use Enqueue\NoEffect\NullMessage;
+use Enqueue\NoEffect\NullQueue;
 use Enqueue\Test\ClassExtensionTrait;
 use Interop\Queue\Consumer;
 use Interop\Queue\Context as InteropContext;

pkg/enqueue/Tests/Client/ConsumptionExtension/LogExtensionTest.php

@@ -13,8 +13,8 @@
 use Enqueue\Consumption\PostMessageReceivedExtensionInterface;
 use Enqueue\Consumption\Result;
 use Enqueue\Consumption\StartExtensionInterface;
-use Enqueue\Null\NullMessage;
-use Enqueue\Null\NullQueue;
+use Enqueue\NoEffect\NullMessage;
+use Enqueue\NoEffect\NullQueue;
 use Enqueue\Test\ClassExtensionTrait;
 use Enqueue\Util\Stringify;
 use Interop\Queue\Consumer;

pkg/enqueue/Tests/Client/ConsumptionExtension/SetRouterPropertiesExtensionTest.php

@@ -7,8 +7,8 @@
 use Enqueue\Client\DriverInterface;
 use Enqueue\Consumption\Context\MessageReceived;
 use Enqueue\Consumption\MessageReceivedExtensionInterface;
-use Enqueue\Null\NullMessage;
-use Enqueue\Null\NullQueue;
+use Enqueue\NoEffect\NullMessage;
+use Enqueue\NoEffect\NullQueue;
 use Enqueue\Test\ClassExtensionTrait;
 use Interop\Queue\Consumer;
 use Interop\Queue\Context as InteropContext;

pkg/enqueue/Tests/Client/DelegateProcessorTest.php

@@ -4,7 +4,7 @@
 
 use Enqueue\Client\Config;
 use Enqueue\Client\DelegateProcessor;
-use Enqueue\Null\NullMessage;
+use Enqueue\NoEffect\NullMessage;
 use Enqueue\ProcessorRegistryInterface;
 use Interop\Queue\Context;
 use Interop\Queue\Processor;

pkg/enqueue/Tests/Client/Driver/GenericDriverTest.php

@@ -7,9 +7,9 @@
 use Enqueue\Client\Driver\GenericDriver;
 use Enqueue\Client\DriverInterface;
 use Enqueue\Client\MessagePriority;
-use Enqueue\Null\NullMessage;
-use Enqueue\Null\NullQueue;
-use Enqueue\Null\NullTopic;
+use Enqueue\NoEffect\NullMessage;
+use Enqueue\NoEffect\NullQueue;
+use Enqueue\NoEffect\NullTopic;
 use Enqueue\Test\ClassExtensionTrait;
 use Interop\Queue\Context;
 use Interop\Queue\Message as InteropMessage;

pkg/enqueue/Tests/Client/DriverFactoryTest.php

@@ -28,8 +28,8 @@
 use Enqueue\Gps\GpsContext;
 use Enqueue\Mongodb\MongodbConnectionFactory;
 use Enqueue\Mongodb\MongodbContext;
-use Enqueue\Null\NullConnectionFactory;
-use Enqueue\Null\NullContext;
+use Enqueue\NoEffect\NullConnectionFactory;
+use Enqueue\NoEffect\NullContext;
 use Enqueue\Pheanstalk\PheanstalkConnectionFactory;
 use Enqueue\Pheanstalk\PheanstalkContext;
 use Enqueue\RdKafka\RdKafkaConnectionFactory;

pkg/enqueue/Tests/Client/RouterProcessorTest.php

@@ -10,8 +10,8 @@
 use Enqueue\Client\RouteCollection;
 use Enqueue\Client\RouterProcessor;
 use Enqueue\Consumption\Result;
-use Enqueue\Null\NullContext;
-use Enqueue\Null\NullMessage;
+use Enqueue\NoEffect\NullContext;
+use Enqueue\NoEffect\NullMessage;
 use Enqueue\Test\ClassExtensionTrait;
 use Enqueue\Test\ReadAttributeTrait;
 use Interop\Queue\Destination;
@@ -188,7 +188,7 @@ public function testShouldDoNotModifyOriginalMessage()
 
         $result = $processor->process($message, new NullContext());
 
-        //guard
+        // guard
         $this->assertEquals(Result::ACK, $result->getStatus());
 
         $this->assertSame('theBody', $message->getBody());

pkg/enqueue/Tests/ConnectionFactoryFactoryTest.php

@@ -12,7 +12,7 @@
 use Enqueue\Gearman\GearmanConnectionFactory;
 use Enqueue\Gps\GpsConnectionFactory;
 use Enqueue\Mongodb\MongodbConnectionFactory;
-use Enqueue\Null\NullConnectionFactory;
+use Enqueue\NoEffect\NullConnectionFactory;
 use Enqueue\Pheanstalk\PheanstalkConnectionFactory;
 use Enqueue\RdKafka\RdKafkaConnectionFactory;
 use Enqueue\Redis\RedisConnectionFactory;

pkg/enqueue/Tests/Consumption/CallbackProcessorTest.php

@@ -3,8 +3,8 @@
 namespace Enqueue\Tests\Consumption;
 
 use Enqueue\Consumption\CallbackProcessor;
-use Enqueue\Null\NullContext;
-use Enqueue\Null\NullMessage;
+use Enqueue\NoEffect\NullContext;
+use Enqueue\NoEffect\NullMessage;
 use Enqueue\Test\ClassExtensionTrait;
 use Interop\Queue\Processor;
 use PHPUnit\Framework\TestCase;

pkg/enqueue/Tests/Consumption/Extension/LogExtensionTest.php

@@ -12,8 +12,8 @@
 use Enqueue\Consumption\PostMessageReceivedExtensionInterface;
 use Enqueue\Consumption\Result;
 use Enqueue\Consumption\StartExtensionInterface;
-use Enqueue\Null\NullMessage;
-use Enqueue\Null\NullQueue;
+use Enqueue\NoEffect\NullMessage;
+use Enqueue\NoEffect\NullQueue;
 use Enqueue\Test\ClassExtensionTrait;
 use Enqueue\Util\Stringify;
 use Interop\Queue\Consumer;

pkg/enqueue/Tests/Consumption/Extension/ReplyExtensionTest.php

@@ -6,8 +6,8 @@
 use Enqueue\Consumption\Extension\ReplyExtension;
 use Enqueue\Consumption\PostMessageReceivedExtensionInterface;
 use Enqueue\Consumption\Result;
-use Enqueue\Null\NullMessage;
-use Enqueue\Null\NullQueue;
+use Enqueue\NoEffect\NullMessage;
+use Enqueue\NoEffect\NullQueue;
 use Enqueue\Test\ClassExtensionTrait;
 use Interop\Queue\Consumer;
 use Interop\Queue\Context;

pkg/enqueue/Tests/Consumption/QueueConsumerTest.php

@@ -20,7 +20,7 @@
 use Enqueue\Consumption\ExtensionInterface;
 use Enqueue\Consumption\QueueConsumer;
 use Enqueue\Consumption\Result;
-use Enqueue\Null\NullQueue;
+use Enqueue\NoEffect\NullQueue;
 use Enqueue\Test\ReadAttributeTrait;
 use Enqueue\Tests\Consumption\Mock\BreakCycleExtension;
 use Enqueue\Tests\Consumption\Mock\DummySubscriptionConsumer;

pkg/enqueue/Tests/Consumption/ResultTest.php

@@ -3,7 +3,7 @@
 namespace Enqueue\Tests\Consumption;
 
 use Enqueue\Consumption\Result;
-use Enqueue\Null\NullMessage;
+use Enqueue\NoEffect\NullMessage;
 use PHPUnit\Framework\TestCase;
 
 class ResultTest extends TestCase

pkg/enqueue/Tests/Router/RouteRecipientListProcessorTest.php

@@ -3,8 +3,8 @@
 namespace Enqueue\Tests\Router;
 
 use Enqueue\Consumption\Result;
-use Enqueue\Null\NullMessage;
-use Enqueue\Null\NullQueue;
+use Enqueue\NoEffect\NullMessage;
+use Enqueue\NoEffect\NullQueue;
 use Enqueue\Router\Recipient;
 use Enqueue\Router\RecipientListRouterInterface;
 use Enqueue\Router\RouteRecipientListProcessor;

pkg/enqueue/Tests/Rpc/PromiseTest.php

@@ -2,7 +2,7 @@
 
 namespace Enqueue\Tests\Rpc;
 
-use Enqueue\Null\NullMessage;
+use Enqueue\NoEffect\NullMessage;
 use Enqueue\Rpc\Promise;
 use PHPUnit\Framework\TestCase;
 

pkg/enqueue/Tests/Rpc/RpcClientTest.php

@@ -2,9 +2,9 @@
 
 namespace Enqueue\Tests\Rpc;
 
-use Enqueue\Null\NullContext;
-use Enqueue\Null\NullMessage;
-use Enqueue\Null\NullQueue;
+use Enqueue\NoEffect\NullContext;
+use Enqueue\NoEffect\NullMessage;
+use Enqueue\NoEffect\NullQueue;
 use Enqueue\Rpc\Promise;
 use Enqueue\Rpc\RpcClient;
 use Interop\Queue\Consumer;

pkg/enqueue/Tests/Symfony/Client/ConsumeCommandTest.php

@@ -13,7 +13,7 @@
 use Enqueue\Consumption\QueueConsumer;
 use Enqueue\Consumption\QueueConsumerInterface;
 use Enqueue\Container\Container;
-use Enqueue\Null\NullQueue;
+use Enqueue\NoEffect\NullQueue;
 use Enqueue\Symfony\Client\ConsumeCommand;
 use Enqueue\Test\ClassExtensionTrait;
 use Interop\Queue\Consumer;

pkg/enqueue/Tests/Symfony/Client/Mock/SetupBrokerExtensionCommand.php

@@ -5,7 +5,7 @@
 use Enqueue\Client\Config;
 use Enqueue\Client\Driver\GenericDriver;
 use Enqueue\Client\RouteCollection;
-use Enqueue\Null\NullContext;
+use Enqueue\NoEffect\NullContext;
 use Enqueue\Symfony\Client\SetupBrokerExtensionCommandTrait;
 use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Input\InputInterface;