Updated for Prooph/Common v4

prooph · Jun 29, 2018 · 91cde70 · 91cde70
1 parent 9b807f3
commit 91cde70
Show file tree

Hide file tree

Showing 6 changed files with 17 additions and 8 deletions.
diff --git a/composer.json b/composer.json
@@ -29,15 +29,15 @@
     },
     "require": {
         "php": "~5.5|~7.0",
-        "prooph/common": "^3.5",
+        "prooph/common": "^4.1",
         "bernard/bernard": "1.0.*@dev"
     },
     "require-dev": {
         "prooph/service-bus": "dev-master",
         "phpunit/phpunit": "~4.7",
         "doctrine/dbal" : "~2.4",
         "fabpot/php-cs-fixer": "1.7.*",
-        "satooshi/php-coveralls": "dev-master"
+        "php-coveralls/php-coveralls": "~1.1"
     },
     "autoload": {
         "psr-4": {

diff --git a/src/BernardMessageProducer.php b/src/BernardMessageProducer.php
@@ -50,7 +50,7 @@ public function __construct(Producer $bernardProducer, $queue = null)
     /**
      * @inheritdoc
      */
-    public function __invoke(Message $message, Deferred $deferred = null)
+    public function __invoke(Message $message, Deferred $deferred = null) : void
     {
         if (null !== $deferred) {
             throw new RuntimeException(__CLASS__ . ' cannot handle query messages which require future responses.');

diff --git a/tests/BernardMessageProducerTest.php b/tests/BernardMessageProducerTest.php
@@ -34,7 +34,7 @@
 use Prophecy\Argument;
 use React\Promise\Deferred;
 use Symfony\Component\EventDispatcher\EventDispatcher;
-
+use PHPUnit\Framework\TestCase;
 
 /**
  * Class BernardMessageProducerTest
@@ -132,9 +132,13 @@ public function it_sends_a_command_to_queue_pulls_it_with_consumer_and_forwards_
 
         $doSomethingHandler = new MessageHandler();
 
-        $consumerCommandBus->utilize(new CommandRouter([
+        $router = new CommandRouter([
             $command->messageName() => $doSomethingHandler
-        ]));
+        ]);
+
+        $router->attachToMessageBus($consumerCommandBus);
+
+        $consumerCommandBus->dispatch($command);
 
         //We use a special bernard router which forwards all messages to a command bus or event bus depending on the
         //Prooph\ServiceBus\Message\MessageHeader::TYPE
@@ -169,9 +173,11 @@ public function it_sends_an_event_to_queue_pulls_it_with_consumer_and_forwards_i
 
         $somethingDoneListener = new MessageHandler();
 
-        $consumerEventBus->utilize(new EventRouter([
+        $router = new EventRouter([
             $event->messageName() => [$somethingDoneListener]
-        ]));
+        ]);
+
+        $router->attachToMessageBus($consumerEventBus);
 
         //We use a special bernard router which forwards all messages to a command bus or event bus depending on the
         //Prooph\ServiceBus\Message\MessageHeader::TYPE

diff --git a/tests/BernardMessageTest.php b/tests/BernardMessageTest.php
@@ -12,6 +12,7 @@
 
 use Prooph\Common\Messaging\Message;
 use Prooph\ServiceBus\Message\Bernard\BernardMessage;
+use PHPUnit\Framework\TestCase;
 
 /**
  * Class BernardMessageTest

diff --git a/tests/BernardRouterTest.php b/tests/BernardRouterTest.php
@@ -16,6 +16,7 @@
 use Prooph\ServiceBus\EventBus;
 use Prooph\ServiceBus\Message\Bernard\BernardMessage;
 use Prooph\ServiceBus\Message\Bernard\BernardRouter;
+use PHPUnit\Framework\TestCase;
 
 /**
  * Class BernardRouterTest

diff --git a/tests/BernardSerializerTest.php b/tests/BernardSerializerTest.php
@@ -16,6 +16,7 @@
 use Prooph\ServiceBus\Message\Bernard\BernardMessage;
 use Prooph\ServiceBus\Message\Bernard\BernardSerializer;
 use ProophTest\ServiceBus\Mock\DoSomething;
+use PHPUnit\Framework\TestCase;
 
 /**
  * Class BernardSerializerTest