diff --git a/docker-compose.yml b/docker-compose.yml index cf4c3cb2c..01be96cee 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -18,7 +18,7 @@ services: environment: - AMQP_DSN=amqp://guest:guest@rabbitmq:5672/mqdev - AMQPS_DSN=amqps://guest:guest@rabbitmqssl:5671 - - DOCTINE_DSN=mysql://root:rootpass@mysql/mqdev + - DOCTRINE_DSN=mysql://root:rootpass@mysql/mqdev - RABBITMQ_HOST=rabbitmq - RABBITMQ_USER=guest - RABBITMQ_PASSWORD=guest diff --git a/docs/bundle/debuging.md b/docs/bundle/debugging.md similarity index 100% rename from docs/bundle/debuging.md rename to docs/bundle/debugging.md diff --git a/docs/bundle/functional_testing.md b/docs/bundle/functional_testing.md index 0a6dcffee..9950d691e 100644 --- a/docs/bundle/functional_testing.md +++ b/docs/bundle/functional_testing.md @@ -7,7 +7,7 @@ In this chapter we give some advices on how to test message queue related logic. ## NULL transport -While testing the application you dont usually need to send real message to real broker. +While testing the application you don't usually need to send real message to real broker. Or even have a dependency on a MQ broker. Here's the purpose of the NULL transport. It simple do nothing when you ask it to send a message. diff --git a/docs/bundle/job_queue.md b/docs/bundle/job_queue.md index bd37d971e..67ebd8367 100644 --- a/docs/bundle/job_queue.md +++ b/docs/bundle/job_queue.md @@ -75,7 +75,7 @@ $ bin/console doctrine:schema:update Guarantee that there is only one job with such name running at a time. For example you have a task that builds a search index. -It takes quite a lot of time and you dont want another instance of same task working at the same time. +It takes quite a lot of time and you don't want another instance of same task working at the same time. Here's how to do it: * Write a job processor class: diff --git a/docs/client/message_examples.md b/docs/client/message_examples.md index 11e13a100..dfee533af 100644 --- a/docs/client/message_examples.md +++ b/docs/client/message_examples.md @@ -82,7 +82,7 @@ $producer->sendEvent('aTopic', $message); ## Timestamp, Content type, Message id Those are self describing things. -Usually they are set by Client so you dont have to worry about them. +Usually they are set by Client so you don't have to worry about them. If you do not like what Client set you can always set custom values: ```php diff --git a/docs/client/supported_brokers.md b/docs/client/supported_brokers.md index 80f4e87da..3be5dc334 100644 --- a/docs/client/supported_brokers.md +++ b/docs/client/supported_brokers.md @@ -31,6 +31,6 @@ Here's the list of protocols and Client features supported by them * \* Possible if a RabbitMQ delay plugin is installed. * \*\* Possible if topics (exchanges) are configured on broker side manually. -* \*\*\* Possible if RabbitMQ Managment Plugin is installed. +* \*\*\* Possible if RabbitMQ Management Plugin is installed. [back to index](../index.md) diff --git a/docs/consumption/message_processor.md b/docs/consumption/message_processor.md index fe1d30ae5..9492a4c8d 100644 --- a/docs/consumption/message_processor.md +++ b/docs/consumption/message_processor.md @@ -113,7 +113,7 @@ class SendMailProcessor implements PsrProcessor The consumption component provide some useful extensions, for example there is an extension that makes RPC processing simpler. The producer might wait for a reply from a consumer and in order to send it a processor has to return a reply result. -Dont forget to add `ReplyExtension`. +Don't forget to add `ReplyExtension`. ```php bind('foo_queue', function(PsrMessage $message) { - // process messsage + // process message return PsrProcessor::ACK; }); $queueConsumer->bind('bar_queue', function(PsrMessage $message) { - // process messsage + // process message return PsrProcessor::ACK; }); @@ -158,7 +158,7 @@ $queueConsumer->consume(); It provides an easy to use high level abstraction. The goal of the component is hide as much as possible low level details so you can concentrate on things that really matters. -For example, It configure a broker for you by creating queuest, exchanges and bind them. +For example, It configure a broker for you by creating queues, exchanges and bind them. It provides easy to use services for producing and processing messages. It supports unified format for setting message expiration, delay, timestamp, correlation id. It supports [message bus](http://www.enterpriseintegrationpatterns.com/patterns/messaging/MessageBus.html) so different applications can talk to each other. diff --git a/docs/transport/amqp.md b/docs/transport/amqp.md index ac7636604..347e57984 100644 --- a/docs/transport/amqp.md +++ b/docs/transport/amqp.md @@ -181,7 +181,7 @@ $psrContext->createProducer() ## Send delayed message AMQP specification says nothing about message delaying hence the producer throws `DeliveryDelayNotSupportedException`. -Though the producer (and the context) accepts a delivry delay strategy and if it is set it uses it to send delayed message. +Though the producer (and the context) accepts a delivery delay strategy and if it is set it uses it to send delayed message. The `enqueue/amqp-tools` package provides two RabbitMQ delay strategies, to use them you have to install that package ```php diff --git a/docs/transport/amqp_bunny.md b/docs/transport/amqp_bunny.md index 09b59336e..ce064a9ce 100644 --- a/docs/transport/amqp_bunny.md +++ b/docs/transport/amqp_bunny.md @@ -171,7 +171,7 @@ $psrContext->createProducer() ## Send delayed message AMQP specification says nothing about message delaying hence the producer throws `DeliveryDelayNotSupportedException`. -Though the producer (and the context) accepts a delivry delay strategy and if it is set it uses it to send delayed message. +Though the producer (and the context) accepts a delivery delay strategy and if it is set it uses it to send delayed message. The `enqueue/amqp-tools` package provides two RabbitMQ delay strategies, to use them you have to install that package ```php diff --git a/docs/transport/amqp_lib.md b/docs/transport/amqp_lib.md index e1cd3c8db..f7dbcea09 100644 --- a/docs/transport/amqp_lib.md +++ b/docs/transport/amqp_lib.md @@ -179,7 +179,7 @@ $psrContext->createProducer() ## Send delayed message AMQP specification says nothing about message delaying hence the producer throws `DeliveryDelayNotSupportedException`. -Though the producer (and the context) accepts a delivry delay strategy and if it is set it uses it to send delayed message. +Though the producer (and the context) accepts a delivery delay strategy and if it is set it uses it to send delayed message. The `enqueue/amqp-tools` package provides two RabbitMQ delay strategies, to use them you have to install that package ```php diff --git a/docs/transport/kafka.md b/docs/transport/kafka.md index cb36842a5..77006f9d6 100644 --- a/docs/transport/kafka.md +++ b/docs/transport/kafka.md @@ -8,7 +8,7 @@ The transport uses [Kafka](https://kafka.apache.org/) streaming platform as a MQ * [Send message to queue](#send-message-to-queue) * [Consume message](#consume-message) * [Serialize message](#serialize-message) -* [Chnage offset](#change-offset) +* [Change offset](#change-offset) ## Installation diff --git a/pkg/amqp-bunny/Tests/Spec/AmqpSendAndReceiveTimestampAsIntengerTest.php b/pkg/amqp-bunny/Tests/Spec/AmqpSendAndReceiveTimestampAsIntegerTest.php similarity index 80% rename from pkg/amqp-bunny/Tests/Spec/AmqpSendAndReceiveTimestampAsIntengerTest.php rename to pkg/amqp-bunny/Tests/Spec/AmqpSendAndReceiveTimestampAsIntegerTest.php index 2bf30f816..f253d73c9 100644 --- a/pkg/amqp-bunny/Tests/Spec/AmqpSendAndReceiveTimestampAsIntengerTest.php +++ b/pkg/amqp-bunny/Tests/Spec/AmqpSendAndReceiveTimestampAsIntegerTest.php @@ -8,7 +8,7 @@ /** * @group functional */ -class AmqpSendAndReceiveTimestampAsIntengerTest extends SendAndReceiveTimestampAsIntegerSpec +class AmqpSendAndReceiveTimestampAsIntegerTest extends SendAndReceiveTimestampAsIntegerSpec { /** * {@inheritdoc} diff --git a/pkg/amqp-ext/Tests/Functional/AmqpCommonUseCasesTest.php b/pkg/amqp-ext/Tests/Functional/AmqpCommonUseCasesTest.php index ceba5f51c..b5780b472 100644 --- a/pkg/amqp-ext/Tests/Functional/AmqpCommonUseCasesTest.php +++ b/pkg/amqp-ext/Tests/Functional/AmqpCommonUseCasesTest.php @@ -4,7 +4,7 @@ use Enqueue\AmqpExt\AmqpContext; use Enqueue\Test\RabbitmqAmqpExtension; -use Enqueue\Test\RabbitmqManagmentExtensionTrait; +use Enqueue\Test\RabbitManagementExtensionTrait; use Interop\Amqp\Impl\AmqpBind; use Interop\Amqp\Impl\AmqpMessage; use PHPUnit\Framework\TestCase; @@ -15,7 +15,7 @@ class AmqpCommonUseCasesTest extends TestCase { use RabbitmqAmqpExtension; - use RabbitmqManagmentExtensionTrait; + use RabbitManagementExtensionTrait; /** * @var AmqpContext diff --git a/pkg/amqp-ext/Tests/Functional/AmqpConsumptionUseCasesTest.php b/pkg/amqp-ext/Tests/Functional/AmqpConsumptionUseCasesTest.php index 0191bf930..54fccb719 100644 --- a/pkg/amqp-ext/Tests/Functional/AmqpConsumptionUseCasesTest.php +++ b/pkg/amqp-ext/Tests/Functional/AmqpConsumptionUseCasesTest.php @@ -10,7 +10,7 @@ use Enqueue\Consumption\QueueConsumer; use Enqueue\Consumption\Result; use Enqueue\Test\RabbitmqAmqpExtension; -use Enqueue\Test\RabbitmqManagmentExtensionTrait; +use Enqueue\Test\RabbitManagementExtensionTrait; use Interop\Queue\PsrContext; use Interop\Queue\PsrMessage; use Interop\Queue\PsrProcessor; @@ -22,7 +22,7 @@ class AmqpConsumptionUseCasesTest extends TestCase { use RabbitmqAmqpExtension; - use RabbitmqManagmentExtensionTrait; + use RabbitManagementExtensionTrait; /** * @var AmqpContext diff --git a/pkg/amqp-ext/Tests/Functional/AmqpRpcUseCasesTest.php b/pkg/amqp-ext/Tests/Functional/AmqpRpcUseCasesTest.php index 3db7ec63c..ba8838602 100644 --- a/pkg/amqp-ext/Tests/Functional/AmqpRpcUseCasesTest.php +++ b/pkg/amqp-ext/Tests/Functional/AmqpRpcUseCasesTest.php @@ -6,7 +6,7 @@ use Enqueue\Rpc\Promise; use Enqueue\Rpc\RpcClient; use Enqueue\Test\RabbitmqAmqpExtension; -use Enqueue\Test\RabbitmqManagmentExtensionTrait; +use Enqueue\Test\RabbitManagementExtensionTrait; use Interop\Amqp\Impl\AmqpMessage; use PHPUnit\Framework\TestCase; @@ -16,7 +16,7 @@ class AmqpRpcUseCasesTest extends TestCase { use RabbitmqAmqpExtension; - use RabbitmqManagmentExtensionTrait; + use RabbitManagementExtensionTrait; /** * @var AmqpContext diff --git a/pkg/async-event-dispatcher/Tests/ProxyEventDispatcherTest.php b/pkg/async-event-dispatcher/Tests/ProxyEventDispatcherTest.php index 5e5c6e969..7c8319147 100644 --- a/pkg/async-event-dispatcher/Tests/ProxyEventDispatcherTest.php +++ b/pkg/async-event-dispatcher/Tests/ProxyEventDispatcherTest.php @@ -20,7 +20,7 @@ public function testShouldBeSubClassOfEventDispatcher() public function testShouldSetSyncModeForGivenEventNameOnDispatchAsyncListenersOnly() { - $asyncListenerMock = $this->createAsyncLisenerMock(); + $asyncListenerMock = $this->createAsyncListenerMock(); $asyncListenerMock ->expects($this->once()) ->method('resetSyncMode') @@ -49,7 +49,7 @@ public function testShouldCallAsyncEventButNotOtherOnDispatchAsyncListenersOnly( }); $asyncEventWasCalled = false; - $dispatcher = new AsyncEventDispatcher($trueEventDispatcher, $this->createAsyncLisenerMock()); + $dispatcher = new AsyncEventDispatcher($trueEventDispatcher, $this->createAsyncListenerMock()); $dispatcher->addListener('theEvent', function () use (&$asyncEventWasCalled) { $this->assertInstanceOf(AsyncEventDispatcher::class, func_get_arg(2)); @@ -74,7 +74,7 @@ public function testShouldCallOtherEventIfDispatchedFromAsyncEventOnDispatchAsyn }); $asyncEventWasCalled = false; - $dispatcher = new AsyncEventDispatcher($trueEventDispatcher, $this->createAsyncLisenerMock()); + $dispatcher = new AsyncEventDispatcher($trueEventDispatcher, $this->createAsyncListenerMock()); $dispatcher->addListener('theEvent', function () use (&$asyncEventWasCalled) { $this->assertInstanceOf(AsyncEventDispatcher::class, func_get_arg(2)); @@ -97,7 +97,7 @@ public function testShouldNotCallAsyncEventIfDispatchedFromOtherEventOnDispatchA func_get_arg(2)->dispatch('theOtherAsyncEvent'); }); - $dispatcher = new AsyncEventDispatcher($trueEventDispatcher, $this->createAsyncLisenerMock()); + $dispatcher = new AsyncEventDispatcher($trueEventDispatcher, $this->createAsyncListenerMock()); $dispatcher->addListener('theAsyncEvent', function () { func_get_arg(2)->dispatch('theOtherEvent'); }); @@ -115,7 +115,7 @@ public function testShouldNotCallAsyncEventIfDispatchedFromOtherEventOnDispatchA /** * @return \PHPUnit_Framework_MockObject_MockObject|AsyncListener */ - private function createAsyncLisenerMock() + private function createAsyncListenerMock() { return $this->createMock(AsyncListener::class); } diff --git a/pkg/dbal/Tests/DbalContextTest.php b/pkg/dbal/Tests/DbalContextTest.php index 746a4f83d..88fb11990 100644 --- a/pkg/dbal/Tests/DbalContextTest.php +++ b/pkg/dbal/Tests/DbalContextTest.php @@ -135,7 +135,7 @@ public function testShouldReturnConfig() $this->assertSame($connection, $context->getDbalConnection()); } - public function testShouldThrowBadMethodCallExceptiOnOncreateTemporaryQueueCall() + public function testShouldThrowBadMethodCallExceptionOncreateTemporaryQueueCall() { $context = new DbalContext($connection = $this->createConnectionMock()); diff --git a/pkg/dbal/Tests/Spec/CreateDbalContextTrait.php b/pkg/dbal/Tests/Spec/CreateDbalContextTrait.php index d4c954afb..15c1f75e4 100644 --- a/pkg/dbal/Tests/Spec/CreateDbalContextTrait.php +++ b/pkg/dbal/Tests/Spec/CreateDbalContextTrait.php @@ -8,7 +8,7 @@ trait CreateDbalContextTrait { protected function createDbalContext() { - if (false == $env = getenv('DOCTINE_DSN')) { + if (false == $env = getenv('DOCTRINE_DSN')) { $this->markTestSkipped('The DOCTRINE_DSN env is not available. Skip tests'); } diff --git a/pkg/enqueue-bundle/EnqueueBundle.php b/pkg/enqueue-bundle/EnqueueBundle.php index b22e55250..e007b97dc 100644 --- a/pkg/enqueue-bundle/EnqueueBundle.php +++ b/pkg/enqueue-bundle/EnqueueBundle.php @@ -69,9 +69,9 @@ class_exists(AmqpLibConnectionFactory::class) $extension->setTransportFactory(new AmqpTransportFactory('amqp')); $extension->setTransportFactory(new RabbitMqAmqpTransportFactory('rabbitmq_amqp')); } else { - $amppPackages = ['enqueue/amqp-ext', 'enqueue/amqp-bunny', 'enqueue/amqp-lib']; - $extension->setTransportFactory(new MissingTransportFactory('amqp', $amppPackages)); - $extension->setTransportFactory(new MissingTransportFactory('rabbitmq_amqp', $amppPackages)); + $amqpPackages = ['enqueue/amqp-ext', 'enqueue/amqp-bunny', 'enqueue/amqp-lib']; + $extension->setTransportFactory(new MissingTransportFactory('amqp', $amqpPackages)); + $extension->setTransportFactory(new MissingTransportFactory('rabbitmq_amqp', $amqpPackages)); } if (class_exists(FsConnectionFactory::class)) { diff --git a/pkg/enqueue-bundle/Tests/Functional/App/CustomAppKernel.php b/pkg/enqueue-bundle/Tests/Functional/App/CustomAppKernel.php index 574dc6b39..465196149 100644 --- a/pkg/enqueue-bundle/Tests/Functional/App/CustomAppKernel.php +++ b/pkg/enqueue-bundle/Tests/Functional/App/CustomAppKernel.php @@ -28,7 +28,7 @@ class CustomAppKernel extends Kernel public function setEnqueueConfig(array $config) { $this->enqueueConfig = array_replace_recursive($this->enqueueConfig, $config); - $this->enqueueConfig['client']['app_name'] = str_replace('.', '', uniqid(true)); + $this->enqueueConfig['client']['app_name'] = str_replace('.', '', uniqid('app_name', true)); $this->enqueueConfigId = md5(json_encode($this->enqueueConfig)); $fs = new Filesystem(); diff --git a/pkg/enqueue-bundle/Tests/Functional/UseCasesTest.php b/pkg/enqueue-bundle/Tests/Functional/UseCasesTest.php index db9768ed1..cec646a7c 100644 --- a/pkg/enqueue-bundle/Tests/Functional/UseCasesTest.php +++ b/pkg/enqueue-bundle/Tests/Functional/UseCasesTest.php @@ -104,7 +104,7 @@ public function provideEnqueueConfigs() yield 'default_dbal_as_dsn' => [[ 'transport' => [ - 'default' => getenv('DOCTINE_DSN'), + 'default' => getenv('DOCTRINE_DSN'), ], ]]; @@ -188,7 +188,7 @@ public function provideEnqueueConfigs() yield 'dbal_dsn' => [[ 'transport' => [ 'default' => 'dbal', - 'dbal' => getenv('DOCTINE_DSN'), + 'dbal' => getenv('DOCTRINE_DSN'), ], ]]; diff --git a/pkg/enqueue-bundle/Tests/Unit/DependencyInjection/Compiler/BuildClientExtensionsPassTest.php b/pkg/enqueue-bundle/Tests/Unit/DependencyInjection/Compiler/BuildClientExtensionsPassTest.php index 516cfa553..e98184b84 100644 --- a/pkg/enqueue-bundle/Tests/Unit/DependencyInjection/Compiler/BuildClientExtensionsPassTest.php +++ b/pkg/enqueue-bundle/Tests/Unit/DependencyInjection/Compiler/BuildClientExtensionsPassTest.php @@ -24,7 +24,7 @@ public function testCouldBeConstructedWithoutAnyArguments() new BuildClientExtensionsPass(); } - public function testShouldReplaceFirstArgumentOfExtensionsServiceConstructorWithTaggsExtensions() + public function testShouldReplaceFirstArgumentOfExtensionsServiceConstructorWithTagsExtensions() { $container = new ContainerBuilder(); diff --git a/pkg/enqueue-bundle/Tests/Unit/DependencyInjection/Compiler/BuildConsumptionExtensionsPassTest.php b/pkg/enqueue-bundle/Tests/Unit/DependencyInjection/Compiler/BuildConsumptionExtensionsPassTest.php index 75d3759a7..a7614bc96 100644 --- a/pkg/enqueue-bundle/Tests/Unit/DependencyInjection/Compiler/BuildConsumptionExtensionsPassTest.php +++ b/pkg/enqueue-bundle/Tests/Unit/DependencyInjection/Compiler/BuildConsumptionExtensionsPassTest.php @@ -24,7 +24,7 @@ public function testCouldBeConstructedWithoutAnyArguments() new BuildConsumptionExtensionsPass(); } - public function testShouldReplaceFirstArgumentOfExtensionsServiceConstructorWithTaggsExtensions() + public function testShouldReplaceFirstArgumentOfExtensionsServiceConstructorWithTagsExtensions() { $container = new ContainerBuilder(); diff --git a/pkg/enqueue/Tests/Rpc/PromiseTest.php b/pkg/enqueue/Tests/Rpc/PromiseTest.php index b2cb42a13..7202e67fc 100644 --- a/pkg/enqueue/Tests/Rpc/PromiseTest.php +++ b/pkg/enqueue/Tests/Rpc/PromiseTest.php @@ -31,10 +31,10 @@ public function testOnReceiveShouldCallReceiveCallBack() $receiveInvoked = false; $receivePromise = null; $receiveTimeout = null; - $receivecb = function ($promise, $timout) use (&$receiveInvoked, &$receivePromise, &$receiveTimeout) { + $receivecb = function ($promise, $timeout) use (&$receiveInvoked, &$receivePromise, &$receiveTimeout) { $receiveInvoked = true; $receivePromise = $promise; - $receiveTimeout = $timout; + $receiveTimeout = $timeout; }; $promise = new Promise($receivecb, function () {}, function () {}); diff --git a/pkg/null/Tests/NullContextTest.php b/pkg/null/Tests/NullContextTest.php index 921734c83..a17f42aa9 100644 --- a/pkg/null/Tests/NullContextTest.php +++ b/pkg/null/Tests/NullContextTest.php @@ -90,7 +90,7 @@ public function testShouldAllowCreateProducer() $this->assertInstanceOf(NullProducer::class, $producer); } - public function testShouldCreateTempraryQueueWithUnqiueName() + public function testShouldCreateTemporaryQueueWithUniqueName() { $context = new NullContext(); diff --git a/pkg/simple-client/Tests/Functional/SimpleClientTest.php b/pkg/simple-client/Tests/Functional/SimpleClientTest.php index cedbd11ff..75d508c8d 100644 --- a/pkg/simple-client/Tests/Functional/SimpleClientTest.php +++ b/pkg/simple-client/Tests/Functional/SimpleClientTest.php @@ -8,7 +8,7 @@ use Enqueue\Consumption\Result; use Enqueue\SimpleClient\SimpleClient; use Enqueue\Test\RabbitmqAmqpExtension; -use Enqueue\Test\RabbitmqManagmentExtensionTrait; +use Enqueue\Test\RabbitManagementExtensionTrait; use Interop\Queue\PsrMessage; use PHPUnit\Framework\TestCase; @@ -18,7 +18,7 @@ class SimpleClientTest extends TestCase { use RabbitmqAmqpExtension; - use RabbitmqManagmentExtensionTrait; + use RabbitManagementExtensionTrait; public function setUp() { diff --git a/pkg/stomp/Tests/Client/StompDriverTest.php b/pkg/stomp/Tests/Client/StompDriverTest.php index 187f31c0c..029d275ef 100644 --- a/pkg/stomp/Tests/Client/StompDriverTest.php +++ b/pkg/stomp/Tests/Client/StompDriverTest.php @@ -277,7 +277,7 @@ public function testShouldThrowExceptionIfProcessorQueueNameParameterIsNotSet() $driver->sendToProcessor($message); } - public function testSetupBrokerShouldOnlyLogMessageThatStompDoesNotSupprtBrokerSetup() + public function testSetupBrokerShouldOnlyLogMessageThatStompDoesNotSupportBrokerSetup() { $driver = new StompDriver( $this->createPsrContextMock(), diff --git a/pkg/stomp/Tests/Functional/StompCommonUseCasesTest.php b/pkg/stomp/Tests/Functional/StompCommonUseCasesTest.php index eb0a11b78..19af898a6 100644 --- a/pkg/stomp/Tests/Functional/StompCommonUseCasesTest.php +++ b/pkg/stomp/Tests/Functional/StompCommonUseCasesTest.php @@ -4,7 +4,7 @@ use Enqueue\Stomp\StompContext; use Enqueue\Stomp\StompMessage; -use Enqueue\Test\RabbitmqManagmentExtensionTrait; +use Enqueue\Test\RabbitManagementExtensionTrait; use Enqueue\Test\RabbitmqStompExtension; /** @@ -13,7 +13,7 @@ class StompCommonUseCasesTest extends \PHPUnit\Framework\TestCase { use RabbitmqStompExtension; - use RabbitmqManagmentExtensionTrait; + use RabbitManagementExtensionTrait; /** * @var StompContext diff --git a/pkg/stomp/Tests/Functional/StompConsumptionUseCasesTest.php b/pkg/stomp/Tests/Functional/StompConsumptionUseCasesTest.php index 5bfd73a83..0c6de93f5 100644 --- a/pkg/stomp/Tests/Functional/StompConsumptionUseCasesTest.php +++ b/pkg/stomp/Tests/Functional/StompConsumptionUseCasesTest.php @@ -9,7 +9,7 @@ use Enqueue\Consumption\QueueConsumer; use Enqueue\Consumption\Result; use Enqueue\Stomp\StompContext; -use Enqueue\Test\RabbitmqManagmentExtensionTrait; +use Enqueue\Test\RabbitManagementExtensionTrait; use Enqueue\Test\RabbitmqStompExtension; use Interop\Queue\PsrContext; use Interop\Queue\PsrMessage; @@ -21,7 +21,7 @@ class StompConsumptionUseCasesTest extends \PHPUnit\Framework\TestCase { use RabbitmqStompExtension; - use RabbitmqManagmentExtensionTrait; + use RabbitManagementExtensionTrait; /** * @var StompContext diff --git a/pkg/stomp/Tests/Functional/StompRpcUseCasesTest.php b/pkg/stomp/Tests/Functional/StompRpcUseCasesTest.php index 3ece5e486..4e4e8385a 100644 --- a/pkg/stomp/Tests/Functional/StompRpcUseCasesTest.php +++ b/pkg/stomp/Tests/Functional/StompRpcUseCasesTest.php @@ -6,7 +6,7 @@ use Enqueue\Rpc\RpcClient; use Enqueue\Stomp\StompContext; use Enqueue\Stomp\StompMessage; -use Enqueue\Test\RabbitmqManagmentExtensionTrait; +use Enqueue\Test\RabbitManagementExtensionTrait; use Enqueue\Test\RabbitmqStompExtension; /** @@ -15,7 +15,7 @@ class StompRpcUseCasesTest extends \PHPUnit\Framework\TestCase { use RabbitmqStompExtension; - use RabbitmqManagmentExtensionTrait; + use RabbitManagementExtensionTrait; /** * @var StompContext diff --git a/pkg/test/RabbitmqManagmentExtensionTrait.php b/pkg/test/RabbitManagementExtensionTrait.php similarity index 98% rename from pkg/test/RabbitmqManagmentExtensionTrait.php rename to pkg/test/RabbitManagementExtensionTrait.php index 660e20d58..c7665882a 100644 --- a/pkg/test/RabbitmqManagmentExtensionTrait.php +++ b/pkg/test/RabbitManagementExtensionTrait.php @@ -2,7 +2,7 @@ namespace Enqueue\Test; -trait RabbitmqManagmentExtensionTrait +trait RabbitManagementExtensionTrait { /** * @param string $queueName