@@ -67,8 +67,8 @@ |
||
67 | 67 | if (null === $id) { |
68 | 68 | throw new \InvalidArgumentException( |
69 | 69 | sprintf( |
70 | - "Invalid command. It does not identify the target aggregate. ". |
|
71 | - "Make sure at least one of the fields or methods in the [%s] class contains the ". |
|
70 | + "Invalid command. It does not identify the target aggregate. " . |
|
71 | + "Make sure at least one of the fields or methods in the [%s] class contains the " . |
|
72 | 72 | "@TargetAggregateIdentifier annotation and that it returns a non-null value.", |
73 | 73 | $command->getPayloadType() |
74 | 74 | ) |
@@ -104,7 +104,7 @@ discard block |
||
104 | 104 | $dispatchMessage = DispatchMessage::fromBytes($this->serializer, $data[1]); |
105 | 105 | $self = $this; |
106 | 106 | |
107 | - $successCallback = function ($result) use ($dispatchMessage, $self) { |
|
107 | + $successCallback = function($result) use ($dispatchMessage, $self) { |
|
108 | 108 | $message = new ReplyMessage( |
109 | 109 | $dispatchMessage->getCommandIdentifier(), |
110 | 110 | $self->serializer, |
@@ -114,7 +114,7 @@ discard block |
||
114 | 114 | $self->template->writeCommandReply($dispatchMessage->getCommandIdentifier(), $message->toBytes()); |
115 | 115 | }; |
116 | 116 | |
117 | - $failureCallback = function (\Exception $cause) use ($dispatchMessage, $self) { |
|
117 | + $failureCallback = function(\Exception $cause) use ($dispatchMessage, $self) { |
|
118 | 118 | $message = new ReplyMessage( |
119 | 119 | $dispatchMessage->getCommandIdentifier(), |
120 | 120 | $self->serializer, |
@@ -94,7 +94,7 @@ |
||
94 | 94 | $this->connector->send($routingKey, $command, $callback); |
95 | 95 | } catch (\Exception $ex) { |
96 | 96 | $this->logger->error( |
97 | - self::DISPATCH_ERROR_MESSAGE.' {err}', |
|
97 | + self::DISPATCH_ERROR_MESSAGE . ' {err}', |
|
98 | 98 | [ |
99 | 99 | 'err' => $ex->getMessage() |
100 | 100 | ] |
@@ -63,6 +63,6 @@ |
||
63 | 63 | protected function doResolveRoutingKey(CommandMessageInterface $command) |
64 | 64 | { |
65 | 65 | $value = $command->getMetaData()->get($this->metaDataKey); |
66 | - return isset($value) ? (string)$value : null; |
|
66 | + return isset($value) ? (string) $value : null; |
|
67 | 67 | } |
68 | 68 | } |
69 | 69 | \ No newline at end of file |
@@ -70,7 +70,7 @@ |
||
70 | 70 | * @param string|mixed $object |
71 | 71 | * @return \ReflectionClass |
72 | 72 | */ |
73 | - public static function getClass ($object) |
|
73 | + public static function getClass($object) |
|
74 | 74 | { |
75 | 75 | $reflectionClass = new \ReflectionClass($object); |
76 | 76 |
@@ -40,7 +40,7 @@ |
||
40 | 40 | * @author "David Kalosi" <[email protected]> |
41 | 41 | * @license <a href="http://www.opensource.org/licenses/mit-license.php">MIT License</a> |
42 | 42 | */ |
43 | -class AmqpTerminal implements TerminalInterface, LoggerAwareInterface |
|
43 | +class AmqpTerminal implements TerminalInterface, LoggerAwareInterface |
|
44 | 44 | { |
45 | 45 | |
46 | 46 | const DEFAULT_EXCHANGE_NAME = "Governor.EventBus"; |
@@ -79,7 +79,7 @@ |
||
79 | 79 | $base = join(DIRECTORY_SEPARATOR, array($this->baseDirectory, $type)); |
80 | 80 | |
81 | 81 | if (!file_exists($base) && !mkdir($base)) { |
82 | - throw new \RuntimeException (sprintf("Could not create directory %s", $base)); |
|
82 | + throw new \RuntimeException(sprintf("Could not create directory %s", $base)); |
|
83 | 83 | } |
84 | 84 | |
85 | 85 | return join(DIRECTORY_SEPARATOR, array($base, $identifier)) . "." . $extension; |
@@ -50,7 +50,7 @@ |
||
50 | 50 | public function asMongoObject() |
51 | 51 | { |
52 | 52 | return [ |
53 | - $this->property->getName() => (string)$this->expression |
|
53 | + $this->property->getName() => (string) $this->expression |
|
54 | 54 | ]; |
55 | 55 | |
56 | 56 | } |
@@ -57,6 +57,6 @@ |
||
57 | 57 | |
58 | 58 | public function asMongoObject() |
59 | 59 | { |
60 | - return [$this->property->getName() => [$this->operator => (string)$this->expression]]; |
|
60 | + return [$this->property->getName() => [$this->operator => (string) $this->expression]]; |
|
61 | 61 | } |
62 | 62 | } |
63 | 63 | \ No newline at end of file |