diff --git a/.php_cs.cache b/.php_cs.cache index 1fcdc11..d09c83f 100644 --- a/.php_cs.cache +++ b/.php_cs.cache @@ -1 +1 @@ -{"php":"7.2.7","version":"2.13.1:v2.13.1#54814c62d5beef3ba55297b9b3186ed8b8a1b161","rules":{"blank_line_after_namespace":true,"braces":true,"class_definition":true,"elseif":true,"function_declaration":true,"indentation_type":true,"line_ending":true,"lowercase_constants":true,"lowercase_keywords":true,"method_argument_space":true,"no_break_comment":true,"no_closing_tag":true,"no_spaces_after_function_name":true,"no_spaces_inside_parenthesis":true,"no_trailing_whitespace":true,"no_trailing_whitespace_in_comment":true,"single_blank_line_at_eof":true,"single_class_element_per_statement":true,"single_import_per_statement":true,"single_line_after_imports":true,"switch_case_semicolon_to_colon":true,"switch_case_space":true,"visibility_required":true,"encoding":true,"full_opening_tag":true,"array_syntax":{"syntax":"short"},"binary_operator_spaces":{"align_double_arrow":false,"align_equals":false},"blank_line_after_opening_tag":true,"blank_line_before_return":true,"cast_spaces":true,"combine_consecutive_unsets":true,"declare_strict_types":true,"function_typehint_space":true,"hash_to_slash_comment":true,"header_comment":{"commentType":"PHPDoc","header":"This file is part of prooph\/psb-enqueue-producer.\n(c) 2017-2018 prooph software GmbH \n(c) 2017-2018 Sascha-Oliver Prolic \n(c) 2017-2018 Formapro \n\nFor the full copyright and license information, please view the LICENSE\nfile that was distributed with this source code.","location":"after_open","separate":"both"},"include":true,"linebreak_after_opening_tag":true,"method_separation":true,"modernize_types_casting":true,"native_function_casing":true,"native_function_invocation":true,"new_with_braces":true,"no_alias_functions":true,"no_blank_lines_after_class_opening":true,"no_empty_statement":true,"no_extra_consecutive_blank_lines":true,"no_leading_import_slash":true,"no_leading_namespace_whitespace":true,"no_multiline_whitespace_around_double_arrow":true,"no_multiline_whitespace_before_semicolons":true,"no_short_bool_cast":true,"no_short_echo_tag":true,"no_singleline_whitespace_before_semicolons":true,"no_spaces_around_offset":true,"no_trailing_comma_in_list_call":true,"no_trailing_comma_in_singleline_array":true,"no_unneeded_control_parentheses":true,"no_unreachable_default_argument_value":true,"no_unused_imports":true,"no_useless_else":true,"no_useless_return":true,"no_whitespace_before_comma_in_array":true,"no_whitespace_in_blank_line":true,"normalize_index_brace":true,"not_operator_with_successor_space":true,"object_operator_without_whitespace":true,"ordered_imports":true,"phpdoc_indent":true,"phpdoc_inline_tag":true,"psr4":true,"return_type_declaration":true,"semicolon_after_instruction":true,"short_scalar_cast":true,"single_quote":true,"standardize_not_equals":true,"strict_comparison":true,"ternary_operator_spaces":true,"trailing_comma_in_multiline_array":true,"trim_array_spaces":true,"unary_operator_spaces":true,"whitespace_after_comma_in_array":true},"hashes":{"tests\/EnqueueMessageProcessorTest.php":3815662491,"tests\/Container\/EnqueueMessageProducerFactoryTest.php":782766176,"tests\/Container\/SimpleClientFactoryTest.php":126322988,"tests\/Container\/EnqueueMessageProcessorFactoryTest.php":3095212297,"tests\/Container\/EnqueueSerializerFactoryTest.php":799520594,"tests\/EnqueueMessageProducerTest.php":1209135651,"tests\/EnqueueSerializerTest.php":3701389502,"tests\/Functional\/EnqueueMessageProducerTest.php":3742305548,"src\/EnqueueMessageProcessor.php":2204242335,"src\/Container\/EnqueueMessageProcessorFactory.php":1085689222,"src\/Container\/SimpleClientFactory.php":1732585029,"src\/Container\/EnqueueMessageProducerFactory.php":2781803735,"src\/Container\/EnqueueSerializerFactory.php":1499720732,"src\/DelayedMessage.php":3076412878,"src\/EnqueueMessageProducer.php":2706937046,"src\/EnqueueSerializer.php":467468541}} \ No newline at end of file +{"php":"7.2.13","version":"2.14.2:v2.14.2#ff401e58261ffc5934a58f795b3f95b355e276cb","rules":{"blank_line_after_namespace":true,"braces":true,"class_definition":true,"elseif":true,"function_declaration":true,"indentation_type":true,"line_ending":true,"lowercase_constants":true,"lowercase_keywords":true,"method_argument_space":true,"no_break_comment":true,"no_closing_tag":true,"no_spaces_after_function_name":true,"no_spaces_inside_parenthesis":true,"no_trailing_whitespace":true,"no_trailing_whitespace_in_comment":true,"single_blank_line_at_eof":true,"single_class_element_per_statement":true,"single_import_per_statement":true,"single_line_after_imports":true,"switch_case_semicolon_to_colon":true,"switch_case_space":true,"visibility_required":true,"encoding":true,"full_opening_tag":true,"array_syntax":{"syntax":"short"},"binary_operator_spaces":{"align_double_arrow":false,"align_equals":false},"blank_line_after_opening_tag":true,"blank_line_before_return":true,"cast_spaces":true,"combine_consecutive_unsets":true,"declare_strict_types":true,"function_typehint_space":true,"hash_to_slash_comment":true,"header_comment":{"commentType":"PHPDoc","header":"This file is part of prooph\/psb-enqueue-producer.\n(c) 2017-2019 prooph software GmbH \n(c) 2017-2019 Sascha-Oliver Prolic \n(c) 2017-2019 Formapro \n\nFor the full copyright and license information, please view the LICENSE\nfile that was distributed with this source code.","location":"after_open","separate":"both"},"include":true,"linebreak_after_opening_tag":true,"method_separation":true,"modernize_types_casting":true,"native_function_casing":true,"native_function_invocation":true,"new_with_braces":true,"no_alias_functions":true,"no_blank_lines_after_class_opening":true,"no_empty_statement":true,"no_extra_consecutive_blank_lines":true,"no_leading_import_slash":true,"no_leading_namespace_whitespace":true,"no_multiline_whitespace_around_double_arrow":true,"no_multiline_whitespace_before_semicolons":true,"no_short_bool_cast":true,"no_short_echo_tag":true,"no_singleline_whitespace_before_semicolons":true,"no_spaces_around_offset":true,"no_trailing_comma_in_list_call":true,"no_trailing_comma_in_singleline_array":true,"no_unneeded_control_parentheses":true,"no_unreachable_default_argument_value":true,"no_unused_imports":true,"no_useless_else":true,"no_useless_return":true,"no_whitespace_before_comma_in_array":true,"no_whitespace_in_blank_line":true,"normalize_index_brace":true,"not_operator_with_successor_space":true,"object_operator_without_whitespace":true,"ordered_imports":true,"phpdoc_indent":true,"phpdoc_inline_tag":true,"psr4":true,"return_type_declaration":true,"semicolon_after_instruction":true,"short_scalar_cast":true,"single_quote":true,"standardize_not_equals":true,"strict_comparison":true,"ternary_operator_spaces":true,"trailing_comma_in_multiline_array":true,"trim_array_spaces":true,"unary_operator_spaces":true,"whitespace_after_comma_in_array":true},"hashes":{"tests\/Container\/SimpleClientFactoryTest.php":3266788591,"tests\/Container\/EnqueueMessageProducerFactoryTest.php":827777560,"tests\/Container\/EnqueueSerializerFactoryTest.php":124930093,"tests\/Container\/EnqueueMessageProcessorFactoryTest.php":2154445455,"tests\/EnqueueMessageProducerTest.php":2907365961,"tests\/Functional\/EnqueueMessageProducerTest.php":3993810552,"tests\/EnqueueSerializerTest.php":2890420046,"tests\/EnqueueMessageProcessorTest.php":2056475553,"src\/EnqueueMessageProducer.php":1615870662,"src\/EnqueueMessageProcessor.php":3750928404,"src\/Container\/EnqueueMessageProcessorFactory.php":112754104,"src\/Container\/EnqueueMessageProducerFactory.php":1559467916,"src\/Container\/EnqueueSerializerFactory.php":2517922701,"src\/Container\/SimpleClientFactory.php":577065568,"src\/DelayedMessage.php":2426004538,"src\/EnqueueSerializer.php":3455235056}} \ No newline at end of file diff --git a/composer.json b/composer.json index 42faf89..d2f3569 100644 --- a/composer.json +++ b/composer.json @@ -26,23 +26,23 @@ ], "require": { "php": "^7.1", - "enqueue/enqueue": "^0.7|^0.8", + "enqueue/enqueue": "^0.9", "prooph/common" : "^4.1", "prooph/service-bus" : "^6.0", - "queue-interop/queue-interop": "^0.6.1" + "queue-interop/queue-interop": "^0.8" }, "require-dev": { "react/promise": "^2.4.1", - "enqueue/simple-client": "^0.7|^0.8", + "enqueue/simple-client": "^0.9.3", "symfony/filesystem": "^2.1|^3", - "enqueue/fs": "^0.7|^0.8", - "enqueue/null": "^0.7|^0.8", + "enqueue/fs": "^0.9", + "enqueue/null": "^0.9", "psr/container": "^1.0", "sandrokeil/interop-config": "^2.0.1", "phpspec/prophecy": "^1.7", "prooph/php-cs-fixer-config": "^0.3", "phpunit/phpunit": "^6.0", - "enqueue/amqp-tools": "^0.7|^0.8" + "enqueue/amqp-tools": "^0.9" }, "suggest" : { "psr/container": "^1.0 for usage of provided factories", diff --git a/src/Container/EnqueueMessageProcessorFactory.php b/src/Container/EnqueueMessageProcessorFactory.php index 611fc38..0e12f93 100644 --- a/src/Container/EnqueueMessageProcessorFactory.php +++ b/src/Container/EnqueueMessageProcessorFactory.php @@ -2,9 +2,9 @@ /** * This file is part of prooph/psb-enqueue-producer. - * (c) 2017-2018 prooph software GmbH - * (c) 2017-2018 Sascha-Oliver Prolic - * (c) 2017-2018 Formapro + * (c) 2017-2019 prooph software GmbH + * (c) 2017-2019 Sascha-Oliver Prolic + * (c) 2017-2019 Formapro * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. diff --git a/src/Container/EnqueueMessageProducerFactory.php b/src/Container/EnqueueMessageProducerFactory.php index dc3ba68..790d57d 100644 --- a/src/Container/EnqueueMessageProducerFactory.php +++ b/src/Container/EnqueueMessageProducerFactory.php @@ -2,9 +2,9 @@ /** * This file is part of prooph/psb-enqueue-producer. - * (c) 2017-2018 prooph software GmbH - * (c) 2017-2018 Sascha-Oliver Prolic - * (c) 2017-2018 Formapro + * (c) 2017-2019 prooph software GmbH + * (c) 2017-2019 Sascha-Oliver Prolic + * (c) 2017-2019 Formapro * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. diff --git a/src/Container/EnqueueSerializerFactory.php b/src/Container/EnqueueSerializerFactory.php index 3320e33..622666f 100644 --- a/src/Container/EnqueueSerializerFactory.php +++ b/src/Container/EnqueueSerializerFactory.php @@ -2,9 +2,9 @@ /** * This file is part of prooph/psb-enqueue-producer. - * (c) 2017-2018 prooph software GmbH - * (c) 2017-2018 Sascha-Oliver Prolic - * (c) 2017-2018 Formapro + * (c) 2017-2019 prooph software GmbH + * (c) 2017-2019 Sascha-Oliver Prolic + * (c) 2017-2019 Formapro * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. diff --git a/src/Container/SimpleClientFactory.php b/src/Container/SimpleClientFactory.php index adf59bf..ad7ae57 100644 --- a/src/Container/SimpleClientFactory.php +++ b/src/Container/SimpleClientFactory.php @@ -2,9 +2,9 @@ /** * This file is part of prooph/psb-enqueue-producer. - * (c) 2017-2018 prooph software GmbH - * (c) 2017-2018 Sascha-Oliver Prolic - * (c) 2017-2018 Formapro + * (c) 2017-2019 prooph software GmbH + * (c) 2017-2019 Sascha-Oliver Prolic + * (c) 2017-2019 Formapro * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. diff --git a/src/DelayedMessage.php b/src/DelayedMessage.php index c9f7d28..cb7ad50 100644 --- a/src/DelayedMessage.php +++ b/src/DelayedMessage.php @@ -2,9 +2,9 @@ /** * This file is part of prooph/psb-enqueue-producer. - * (c) 2017-2018 prooph software GmbH - * (c) 2017-2018 Sascha-Oliver Prolic - * (c) 2017-2018 Formapro + * (c) 2017-2019 prooph software GmbH + * (c) 2017-2019 Sascha-Oliver Prolic + * (c) 2017-2019 Formapro * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. diff --git a/src/EnqueueMessageProcessor.php b/src/EnqueueMessageProcessor.php index 35141c3..04c5b8b 100644 --- a/src/EnqueueMessageProcessor.php +++ b/src/EnqueueMessageProcessor.php @@ -2,9 +2,9 @@ /** * This file is part of prooph/psb-enqueue-producer. - * (c) 2017-2018 prooph software GmbH - * (c) 2017-2018 Sascha-Oliver Prolic - * (c) 2017-2018 Formapro + * (c) 2017-2019 prooph software GmbH + * (c) 2017-2019 Sascha-Oliver Prolic + * (c) 2017-2019 Formapro * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. @@ -16,9 +16,9 @@ use Enqueue\Consumption\Result; use Enqueue\Util\JSON; -use Interop\Queue\PsrContext; -use Interop\Queue\PsrMessage; -use Interop\Queue\PsrProcessor; +use Interop\Queue\Context as PsrContext; +use Interop\Queue\Message as PsrMessage; +use Interop\Queue\Processor as PsrProcessor; use Prooph\Common\Messaging\Message; use Prooph\ServiceBus\CommandBus; use Prooph\ServiceBus\EventBus; @@ -73,7 +73,7 @@ public function process(PsrMessage $psrMessage, PsrContext $psrContext): Result case Message::TYPE_QUERY: $promise = $this->queryBus->dispatch($message); - $body = null; + $body = ''; $promise->then(function ($value) use (&$body) { $body = JSON::encode($value); }); diff --git a/src/EnqueueMessageProducer.php b/src/EnqueueMessageProducer.php index be82907..1117f1d 100644 --- a/src/EnqueueMessageProducer.php +++ b/src/EnqueueMessageProducer.php @@ -2,9 +2,9 @@ /** * This file is part of prooph/psb-enqueue-producer. - * (c) 2017-2018 prooph software GmbH - * (c) 2017-2018 Sascha-Oliver Prolic - * (c) 2017-2018 Formapro + * (c) 2017-2019 prooph software GmbH + * (c) 2017-2019 Sascha-Oliver Prolic + * (c) 2017-2019 Formapro * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. diff --git a/src/EnqueueSerializer.php b/src/EnqueueSerializer.php index a2169b2..b8c053f 100644 --- a/src/EnqueueSerializer.php +++ b/src/EnqueueSerializer.php @@ -2,9 +2,9 @@ /** * This file is part of prooph/psb-enqueue-producer. - * (c) 2017-2018 prooph software GmbH - * (c) 2017-2018 Sascha-Oliver Prolic - * (c) 2017-2018 Formapro + * (c) 2017-2019 prooph software GmbH + * (c) 2017-2019 Sascha-Oliver Prolic + * (c) 2017-2019 Formapro * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. diff --git a/tests/Container/EnqueueMessageProcessorFactoryTest.php b/tests/Container/EnqueueMessageProcessorFactoryTest.php index 77926ea..af193e6 100644 --- a/tests/Container/EnqueueMessageProcessorFactoryTest.php +++ b/tests/Container/EnqueueMessageProcessorFactoryTest.php @@ -2,9 +2,9 @@ /** * This file is part of prooph/psb-enqueue-producer. - * (c) 2017-2018 prooph software GmbH - * (c) 2017-2018 Sascha-Oliver Prolic - * (c) 2017-2018 Formapro + * (c) 2017-2019 prooph software GmbH + * (c) 2017-2019 Sascha-Oliver Prolic + * (c) 2017-2019 Formapro * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. diff --git a/tests/Container/EnqueueMessageProducerFactoryTest.php b/tests/Container/EnqueueMessageProducerFactoryTest.php index 1c519e6..ede0357 100644 --- a/tests/Container/EnqueueMessageProducerFactoryTest.php +++ b/tests/Container/EnqueueMessageProducerFactoryTest.php @@ -2,9 +2,9 @@ /** * This file is part of prooph/psb-enqueue-producer. - * (c) 2017-2018 prooph software GmbH - * (c) 2017-2018 Sascha-Oliver Prolic - * (c) 2017-2018 Formapro + * (c) 2017-2019 prooph software GmbH + * (c) 2017-2019 Sascha-Oliver Prolic + * (c) 2017-2019 Formapro * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. diff --git a/tests/Container/EnqueueSerializerFactoryTest.php b/tests/Container/EnqueueSerializerFactoryTest.php index d6f27be..717a8fb 100644 --- a/tests/Container/EnqueueSerializerFactoryTest.php +++ b/tests/Container/EnqueueSerializerFactoryTest.php @@ -2,9 +2,9 @@ /** * This file is part of prooph/psb-enqueue-producer. - * (c) 2017-2018 prooph software GmbH - * (c) 2017-2018 Sascha-Oliver Prolic - * (c) 2017-2018 Formapro + * (c) 2017-2019 prooph software GmbH + * (c) 2017-2019 Sascha-Oliver Prolic + * (c) 2017-2019 Formapro * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. diff --git a/tests/Container/SimpleClientFactoryTest.php b/tests/Container/SimpleClientFactoryTest.php index 8a9aadd..88961ca 100644 --- a/tests/Container/SimpleClientFactoryTest.php +++ b/tests/Container/SimpleClientFactoryTest.php @@ -2,9 +2,9 @@ /** * This file is part of prooph/psb-enqueue-producer. - * (c) 2017-2018 prooph software GmbH - * (c) 2017-2018 Sascha-Oliver Prolic - * (c) 2017-2018 Formapro + * (c) 2017-2019 prooph software GmbH + * (c) 2017-2019 Sascha-Oliver Prolic + * (c) 2017-2019 Formapro * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. diff --git a/tests/EnqueueMessageProcessorTest.php b/tests/EnqueueMessageProcessorTest.php index 58d7742..5634af0 100644 --- a/tests/EnqueueMessageProcessorTest.php +++ b/tests/EnqueueMessageProcessorTest.php @@ -2,9 +2,9 @@ /** * This file is part of prooph/psb-enqueue-producer. - * (c) 2017-2018 prooph software GmbH - * (c) 2017-2018 Sascha-Oliver Prolic - * (c) 2017-2018 Formapro + * (c) 2017-2019 prooph software GmbH + * (c) 2017-2019 Sascha-Oliver Prolic + * (c) 2017-2019 Formapro * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. @@ -17,8 +17,8 @@ use Enqueue\Consumption\Result; use Enqueue\Null\NullContext; use Enqueue\Null\NullMessage; -use Interop\Queue\PsrMessage; -use Interop\Queue\PsrProcessor; +use Interop\Queue\Message as PsrMessage; +use Interop\Queue\Processor as PsrProcessor; use PHPUnit\Framework\TestCase; use Prooph\Common\Messaging\DomainMessage; use Prooph\Common\Messaging\PayloadTrait; diff --git a/tests/EnqueueMessageProducerTest.php b/tests/EnqueueMessageProducerTest.php index 19e9890..de1c61f 100644 --- a/tests/EnqueueMessageProducerTest.php +++ b/tests/EnqueueMessageProducerTest.php @@ -2,9 +2,9 @@ /** * This file is part of prooph/psb-enqueue-producer. - * (c) 2017-2018 prooph software GmbH - * (c) 2017-2018 Sascha-Oliver Prolic - * (c) 2017-2018 Formapro + * (c) 2017-2019 prooph software GmbH + * (c) 2017-2019 Sascha-Oliver Prolic + * (c) 2017-2019 Formapro * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. diff --git a/tests/EnqueueSerializerTest.php b/tests/EnqueueSerializerTest.php index 5a9e030..83478f7 100644 --- a/tests/EnqueueSerializerTest.php +++ b/tests/EnqueueSerializerTest.php @@ -2,9 +2,9 @@ /** * This file is part of prooph/psb-enqueue-producer. - * (c) 2017-2018 prooph software GmbH - * (c) 2017-2018 Sascha-Oliver Prolic - * (c) 2017-2018 Formapro + * (c) 2017-2019 prooph software GmbH + * (c) 2017-2019 Sascha-Oliver Prolic + * (c) 2017-2019 Formapro * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. diff --git a/tests/Functional/EnqueueMessageProducerTest.php b/tests/Functional/EnqueueMessageProducerTest.php index 3af3001..4f9b861 100644 --- a/tests/Functional/EnqueueMessageProducerTest.php +++ b/tests/Functional/EnqueueMessageProducerTest.php @@ -2,9 +2,9 @@ /** * This file is part of prooph/psb-enqueue-producer. - * (c) 2017-2018 prooph software GmbH - * (c) 2017-2018 Sascha-Oliver Prolic - * (c) 2017-2018 Formapro + * (c) 2017-2019 prooph software GmbH + * (c) 2017-2019 Sascha-Oliver Prolic + * (c) 2017-2019 Formapro * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. @@ -14,7 +14,6 @@ namespace ProophTest\ServiceBus\Enqueue\Functional; -use Enqueue\Client\Config; use Enqueue\Consumption\ChainExtension; use Enqueue\Consumption\Extension\LimitConsumedMessagesExtension; use Enqueue\Consumption\Extension\LimitConsumptionTimeExtension; @@ -53,6 +52,8 @@ protected function setUp(): void $this->client = new SimpleClient('file://'.__DIR__.'/queues'); + $this->client->getQueueConsumer()->setReceiveTimeout(1); + $this->serializer = new EnqueueSerializer(new FQCNMessageFactory(), new NoOpMessageConverter()); } @@ -66,10 +67,6 @@ public function it_sends_a_command_to_queue_pulls_it_with_consumer_and_forwards_ //The message dispatcher works with a ready-to-use enqueue producer and one queue $messageProducer = new EnqueueMessageProducer($this->client->getProducer(), $this->serializer, 'prooph_bus', 2000); - //Normally you would send the command on a command bus. We skip this step here cause we are only - //interested in the function of the message dispatcher - $messageProducer($command); - //Set up command bus which will receive the command message from the enqueue consumer $consumerCommandBus = new CommandBus(); @@ -80,11 +77,15 @@ public function it_sends_a_command_to_queue_pulls_it_with_consumer_and_forwards_ $router->attachToMessageBus($consumerCommandBus); $enqueueProcessor = new EnqueueMessageProcessor($consumerCommandBus, new EventBus(), new QueryBus(), $this->serializer); - $this->client->bind(Config::COMMAND_TOPIC, 'prooph_bus', $enqueueProcessor); + $this->client->bindCommand('prooph_bus', $enqueueProcessor); + + //Normally you would send the command on a command bus. We skip this step here cause we are only + //interested in the function of the message dispatcher + $messageProducer($command); $this->client->consume(new ChainExtension([ new LimitConsumedMessagesExtension(2), - new LimitConsumptionTimeExtension(new \DateTime('now + 5 seconds')), + new LimitConsumptionTimeExtension(new \DateTime('now + 1 seconds')), ])); $this->assertNotNull($doSomethingHandler->getLastMessage()); @@ -102,10 +103,6 @@ public function it_sends_an_event_to_queue_pulls_it_with_consumer_and_forwards_i //The message dispatcher works with a ready-to-use enqueue producer and one queue $messageProducer = new EnqueueMessageProducer($this->client->getProducer(), $this->serializer, 'prooph_bus', 2000); - //Normally you would send the event on a event bus. We skip this step here cause we are only - //interested in the function of the message dispatcher - $messageProducer($event); - //Set up event bus which will receive the event message from the enqueue consumer $consumerEventBus = new EventBus(); @@ -116,11 +113,15 @@ public function it_sends_an_event_to_queue_pulls_it_with_consumer_and_forwards_i $router->attachToMessageBus($consumerEventBus); $enqueueProcessor = new EnqueueMessageProcessor(new CommandBus(), $consumerEventBus, new QueryBus(), $this->serializer); - $this->client->bind(Config::COMMAND_TOPIC, 'prooph_bus', $enqueueProcessor); + $this->client->bindCommand('prooph_bus', $enqueueProcessor); + + //Normally you would send the event on a event bus. We skip this step here cause we are only + //interested in the function of the message dispatcher + $messageProducer($event); $this->client->consume(new ChainExtension([ new LimitConsumedMessagesExtension(2), - new LimitConsumptionTimeExtension(new \DateTime('now + 5 seconds')), + new LimitConsumptionTimeExtension(new \DateTime('now + 1 seconds')), ])); $this->assertNotNull($somethingDoneListener->getLastMessage());