Route command message through amqp transport.

jorge07 · Dec 17, 2018 · c969c87 · c969c87
1 parent 5b69555
commit c969c87
Show file tree

Hide file tree

Showing 8 changed files with 235 additions and 193 deletions.
diff --git a/composer.lock b/composer.lock
diff --git a/config/packages/messenger.yaml b/config/packages/messenger.yaml
@@ -7,12 +7,12 @@ framework:
             messenger.bus.command:
                 middleware:
                     - messenger.middleware.validation
-                    #- messenger.middleware.handles_recorded_messages: ['@messenger.bus.event']
-                    #- doctrine_transaction_middleware: ['default']
             messenger.bus.query:
                 middleware:
                     - messenger.middleware.validation
             messenger.bus.event:
                 middleware:
                     - messenger.middleware.allow_no_handler
                     - messenger.middleware.validation
+        routing:
+            'App\Application\Command\CommandMessage': amqp
diff --git a/phpunit.xml.dist b/phpunit.xml.dist
@@ -28,7 +28,7 @@
         <!-- ###- lexik/jwt-authentication-bundle ### -->
 
         <!-- ###+ symfony/messenger ### -->
-        <!-- <env name="MESSENGER_TRANSPORT_DSN" value="amqp://guest:guest@localhost:5672/%2f/messages"/> -->
+        <env name="MESSENGER_TRANSPORT_DSN" value="amqp://guest:guest@rmq:5672/%2f/elastic_events"/>
         <!-- ###- symfony/messenger ### -->
     </php>
 

diff --git a/src/Application/Command/CommandMessage.php b/src/Application/Command/CommandMessage.php
@@ -0,0 +1,7 @@
+<?php
+
+namespace App\Application\Command;
+
+interface CommandMessage
+{
+}
diff --git a/src/Application/Command/User/ChangeEmail/ChangeEmailCommand.php b/src/Application/Command/User/ChangeEmail/ChangeEmailCommand.php
@@ -4,10 +4,11 @@
 
 namespace App\Application\Command\User\ChangeEmail;
 
+use App\Application\Command\CommandMessage;
 use App\Domain\User\ValueObject\Email;
 use Ramsey\Uuid\Uuid;
 
-class ChangeEmailCommand
+class ChangeEmailCommand implements CommandMessage
 {
     /** @var \Ramsey\Uuid\UuidInterface */
     public $userUuid;

diff --git a/src/Application/Command/User/SignIn/SignInCommand.php b/src/Application/Command/User/SignIn/SignInCommand.php
@@ -4,9 +4,10 @@
 
 namespace App\Application\Command\User\SignIn;
 
+use App\Application\Command\CommandMessage;
 use App\Domain\User\ValueObject\Email;
 
-class SignInCommand
+class SignInCommand implements CommandMessage
 {
     /**
      * @var Email

diff --git a/src/Application/Command/User/SignUp/SignUpCommand.php b/src/Application/Command/User/SignUp/SignUpCommand.php
@@ -2,13 +2,14 @@
 
 namespace App\Application\Command\User\SignUp;
 
+use App\Application\Command\CommandMessage;
 use App\Domain\User\ValueObject\Auth\Credentials;
 use App\Domain\User\ValueObject\Auth\HashedPassword;
 use App\Domain\User\ValueObject\Email;
 use Ramsey\Uuid\Uuid;
 use Ramsey\Uuid\UuidInterface;
 
-class SignUpCommand
+class SignUpCommand implements CommandMessage
 {
     /**
      * @var UuidInterface

diff --git a/src/Infrastructure/User/Query/Projections/UserView.php b/src/Infrastructure/User/Query/Projections/UserView.php
@@ -14,6 +14,9 @@
 
 class UserView implements UserViewInterface
 {
+    /**
+     * @throws \Assert\AssertionFailedException
+     */
     public static function fromSerializable(Serializable $event): self
     {
         return self::deserialize($event->serialize());