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

composer.json

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

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-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-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/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-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/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;

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

@@ -8,7 +8,7 @@
 use Enqueue\Client\RouteCollection;
 use Enqueue\Consumption\ChainExtension;
 use Enqueue\Consumption\QueueConsumerInterface;
-use Enqueue\Null\NullQueue;
+use Enqueue\NoEffect\NullQueue;
 use Enqueue\Symfony\Client\ConsumeCommand;
 use Enqueue\Symfony\Client\SimpleConsumeCommand;
 use Enqueue\Test\ClassExtensionTrait;

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

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

pkg/fs/Tests/FsContextTest.php

@@ -7,7 +7,7 @@
 use Enqueue\Fs\FsDestination;
 use Enqueue\Fs\FsMessage;
 use Enqueue\Fs\FsProducer;
-use Enqueue\Null\NullQueue;
+use Enqueue\NoEffect\NullQueue;
 use Enqueue\Test\ClassExtensionTrait;
 use Enqueue\Test\ReadAttributeTrait;
 use Interop\Queue\Context;
@@ -116,7 +116,7 @@ public function testShouldThrowIfNotFsDestinationGivenOnCreateConsumer()
         $context = new FsContext(sys_get_temp_dir(), 1, 0666, 100);
 
         $this->expectException(InvalidDestinationException::class);
-        $this->expectExceptionMessage('The destination must be an instance of Enqueue\Fs\FsDestination but got Enqueue\Null\NullQueue.');
+        $this->expectExceptionMessage('The destination must be an instance of Enqueue\Fs\FsDestination but got Enqueue\NoEffect\NullQueue.');
         $consumer = $context->createConsumer(new NullQueue('aQueue'));
 
         $this->assertInstanceOf(FsConsumer::class, $consumer);

pkg/fs/Tests/FsProducerTest.php

@@ -6,8 +6,8 @@
 use Enqueue\Fs\FsDestination;
 use Enqueue\Fs\FsMessage;
 use Enqueue\Fs\FsProducer;
-use Enqueue\Null\NullMessage;
-use Enqueue\Null\NullQueue;
+use Enqueue\NoEffect\NullMessage;
+use Enqueue\NoEffect\NullQueue;
 use Enqueue\Test\ClassExtensionTrait;
 use Interop\Queue\Exception\InvalidDestinationException;
 use Interop\Queue\Exception\InvalidMessageException;
@@ -33,7 +33,7 @@ public function testThrowIfDestinationNotFsOnSend()
         $producer = new FsProducer($this->createContextMock());
 
         $this->expectException(InvalidDestinationException::class);
-        $this->expectExceptionMessage('The destination must be an instance of Enqueue\Fs\FsDestination but got Enqueue\Null\NullQueue.');
+        $this->expectExceptionMessage('The destination must be an instance of Enqueue\Fs\FsDestination but got Enqueue\NoEffect\NullQueue.');
         $producer->send(new NullQueue('aQueue'), new FsMessage());
     }
 
@@ -42,7 +42,7 @@ public function testThrowIfMessageNotFsOnSend()
         $producer = new FsProducer($this->createContextMock());
 
         $this->expectException(InvalidMessageException::class);
-        $this->expectExceptionMessage('The message must be an instance of Enqueue\Fs\FsMessage but it is Enqueue\Null\NullMessage.');
+        $this->expectExceptionMessage('The message must be an instance of Enqueue\Fs\FsMessage but it is Enqueue\NoEffect\NullMessage.');
         $producer->send(new FsDestination(TempFile::generate()), new NullMessage());
     }