SmartGecko / GovernorFramework

src/Governor/Framework/CommandHandling/Distributed/RedisCommandBusConnector.php

Doc Comments +3 added lines

@@ -103,6 +103,9 @@
         }
     }
 
+    /**
+     * @return string
+     */
     private function findSuitableNode(CommandMessageInterface $command)
     {
         $nodes = $this->template->getSubscriptions($command->getCommandName());

src/Governor/Framework/CommandHandling/Distributed/RedisTemplate.php

Doc Comments +8 added lines, -1 removed lines

@@ -143,7 +143,7 @@ 
 
     /**
      * @param string $commandIdentifier
-     * @param mixed $reply
+     * @param string $reply
      */
     public function writeCommandReply($commandIdentifier, $reply)
     {
@@ -200,11 +200,18 @@ 
         );
     }
 
+    /**
+     * @param string $commandName
+     */
     public static function hashCommandName($commandName)
     {
         return hash('md5', $commandName);
     }
 
+    /**
+     * @param string $commandName
+     * @param string $routingKey
+     */
     public static function hashCommandRouting($commandName, $routingKey)
     {
         return hash('md5', sprintf('%s-%s', $commandName, $routingKey));

src/Governor/Framework/Common/AnnotatedMetaDataParameterResolver.php

Doc Comments +3 added lines

@@ -60,6 +60,9 @@
         return $message->getMetaData()->get($this->getKey());

     }

 

+    /**
+     * @return string
+     */
     private function getKey()

     {

         // !!! TODO check types on primitives ?

src/Governor/Framework/EventHandling/Amqp/ChannelTransactionUnitOfWorkListener.php

Doc Comments +3 added lines

@@ -68,6 +68,9 @@
         $this->isOpen = true;
     }
 
+    /**
+     * @param string $propertyName
+     */
     private function getTerminalProperty($propertyName)
     {
         $reflClass = new \ReflectionClass($this->terminal);

src/Governor/Framework/EventHandling/InMemoryEventListenerRegistry.php

Doc Comments +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
     /**
      * Returns an array of registered EventListenerInterface-s.
      *
-     * @return \SplObjectStorage|EventListenerInterface[]
+     * @return \SplObjectStorage
      */
     public function getListeners()
     {

src/Governor/Framework/EventHandling/Listeners/AnnotatedEventListener.php

Doc Comments +3 added lines

@@ -41,6 +41,9 @@
     private $methodName;
     private $eventTarget;
 
+    /**
+     * @param string $eventName
+     */
     function __construct($eventName, $methodName, $eventTarget)
     {
         $this->eventName = $eventName;

src/Governor/Framework/EventSourcing/EventSourcingRepository.php

Doc Comments +3 added lines

@@ -129,6 +129,9 @@
         $this->eventStore->appendEvents($this->getTypeIdentifier(), $eventStream);
     }
 
+    /**
+     * @param string $className
+     */
     private function validateEventSourcedAggregate($className)
     {
         $reflClass = new \ReflectionClass($className);

src/Governor/Framework/EventStore/Filesystem/FilesystemEventMessageReader.php

Doc Comments +4 added lines, -1 removed lines

@@ -32,7 +32,7 @@ 
 
     /**
      *
-     * @return \Governor\Framework\Serializer\SerializedDomainEventDataInterface|null
+     * @return null|SimpleSerializedDomainEventData
      * @throws \RuntimeException
      */
     public function readEventMessage()
@@ -92,6 +92,9 @@ 
         );
     }
 
+    /**
+     * @param integer $length
+     */
     private function readBytes($length)
     {
         $stream = null;

src/Governor/Framework/EventStore/Filesystem/FilesystemEventStore.php

Doc Comments +4 added lines

@@ -112,6 +112,10 @@
         return new FilesystemDomainEventStream($file, $this->serializer);
     }
 
+    /**
+     * @param string $type
+     * @param \SplFileObject $eventFile
+     */
     private function readSnapshotEvent($type, $identifier, $eventFile)
     {
         $snapshotEvent = null;