@@ -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 |