mgdigital / BusQue

src/SystemClock.php

Spacing +1 added lines, -1 removed lines

@@ -5,7 +5,7 @@
 class SystemClock implements ClockInterface
 {
 
-    public function getTime(): \DateTime
+    public function getTime (): \DateTime
     {
         return new \DateTime();
     }

src/Implementation.php

Spacing +9 added lines, -9 removed lines

@@ -14,7 +14,7 @@ 
     private $commandBusAdapter;
     private $errorHandler;
 
-    public function __construct(
+    public function __construct (
         QueueResolverInterface $queueResolver,
         CommandSerializerInterface $commandSerializer,
         CommandIdGeneratorInterface $commandIdGenerator,
@@ -34,42 +34,42 @@ 
         $this->errorHandler = $errorHandler;
     }
 
-    public function getQueueResolver(): QueueResolverInterface
+    public function getQueueResolver (): QueueResolverInterface
     {
         return $this->queueResolver;
     }
 
-    public function getCommandSerializer(): CommandSerializerInterface
+    public function getCommandSerializer (): CommandSerializerInterface
     {
         return $this->commandSerializer;
     }
 
-    public function getCommandIdGenerator(): CommandIdGeneratorInterface
+    public function getCommandIdGenerator (): CommandIdGeneratorInterface
     {
         return $this->commandIdGenerator;
     }
 
-    public function getQueueAdapter(): QueueAdapterInterface
+    public function getQueueAdapter (): QueueAdapterInterface
     {
         return $this->queueAdapter;
     }
 
-    public function getSchedulerAdapter(): SchedulerAdapterInterface
+    public function getSchedulerAdapter (): SchedulerAdapterInterface
     {
         return $this->schedulerAdapter;
     }
 
-    public function getClock(): ClockInterface
+    public function getClock (): ClockInterface
     {
         return $this->clock;
     }
 
-    public function getCommandBusAdapter(): CommandBusAdapterInterface
+    public function getCommandBusAdapter (): CommandBusAdapterInterface
     {
         return $this->commandBusAdapter;
     }
 
-    public function getErrorHandler(): ErrorHandlerInterface
+    public function getErrorHandler (): ErrorHandlerInterface
     {
         return $this->errorHandler;
     }

src/CommandBusAdapterInterface.php

Spacing +1 added lines, -1 removed lines

@@ -5,5 +5,5 @@
 interface CommandBusAdapterInterface
 {
 
-    public function handle($command);
+    public function handle ($command);
 }

src/ReceivedCommand.php

Spacing +4 added lines, -4 removed lines

@@ -9,24 +9,24 @@
     private $id;
     private $serialized;
 
-    public function __construct(string $queueName, string $id, string $serialized)
+    public function __construct (string $queueName, string $id, string $serialized)
     {
         $this->queueName = $queueName;
         $this->id = $id;
         $this->serialized = $serialized;
     }
 
-    public function getQueueName(): string
+    public function getQueueName (): string
     {
         return $this->queueName;
     }
 
-    public function getId(): string
+    public function getId (): string
     {
         return $this->id;
     }
 
-    public function getSerialized(): string
+    public function getSerialized (): string
     {
         return $this->serialized;
     }

src/QueueAdapterInterface.php

Spacing +14 added lines, -14 removed lines

@@ -15,29 +15,29 @@ 
     const STATUS_FAILED = 'failed';
     const STATUS_NOT_FOUND = 'not_found';
 
-    public function queueCommand(string $queueName, string $id, string $serialized);
+    public function queueCommand (string $queueName, string $id, string $serialized);
 
-    public function getCommandStatus(string $queueName, string $id): string;
+    public function getCommandStatus (string $queueName, string $id): string;
 
-    public function setCommandCompleted(string $queueName, string $id);
+    public function setCommandCompleted (string $queueName, string $id);
 
-    public function setCommandFailed(string $queueName, string $id);
+    public function setCommandFailed (string $queueName, string $id);
 
-    public function getQueueNames(): array;
+    public function getQueueNames (): array;
 
-    public function getQueuedCount(string $queueName): int;
+    public function getQueuedCount (string $queueName): int;
 
-    public function getConsumingCount(string $queueName): int;
+    public function getConsumingCount (string $queueName): int;
 
-    public function emptyQueue(string $queueName);
+    public function emptyQueue (string $queueName);
 
-    public function putQueue(string $queueName);
+    public function putQueue (string $queueName);
 
-    public function purgeCommand(string $queueName, string $id);
+    public function purgeCommand (string $queueName, string $id);
 
-    public function getQueuedIds(string $queueName, int $offset = 0, int $limit = 10): array;
+    public function getQueuedIds (string $queueName, int $offset = 0, int $limit = 10): array;
 
-    public function getConsumingIds(string $queueName, int $offset = 0, int $limit = 10): array;
+    public function getConsumingIds (string $queueName, int $offset = 0, int $limit = 10): array;
 
     /**
      * @param string $queueName
@@ -45,12 +45,12 @@ 
      * @return string The serialized command
      * @throws CommandNotFoundException
      */
-    public function readCommand(string $queueName, string $id): string;
+    public function readCommand (string $queueName, string $id): string;
 
     /**
      * @param string $queueName
      * @return ReceivedCommand
      * @throws TimeoutException
      */
-    public function awaitCommand(string $queueName, int $timeout = null): ReceivedCommand;
+    public function awaitCommand (string $queueName, int $timeout = null): ReceivedCommand;
 }

src/Serializer/JMSCommandSerializer.php

Spacing +3 added lines, -3 removed lines

@@ -12,19 +12,19 @@
     private $type;
     private $format;
 
-    public function __construct(SerializerInterface $jmsSerializer, string $type, string $format = 'json')
+    public function __construct (SerializerInterface $jmsSerializer, string $type, string $format = 'json')
     {
         $this->jmsSerializer = $jmsSerializer;
         $this->type = $type;
         $this->format = $format;
     }
 
-    public function serialize($command): string
+    public function serialize ($command): string
     {
         return $this->jmsSerializer->serialize($command, $this->format);
     }
 
-    public function unserialize(string $serialized)
+    public function unserialize (string $serialized)
     {
         return $this->jmsSerializer->deserialize($serialized, $this->type, $this->format);
     }

src/Serializer/PHPCommandSerializer.php

Spacing +2 added lines, -2 removed lines

@@ -7,12 +7,12 @@
 class PHPCommandSerializer implements CommandSerializerInterface
 {
 
-    public function serialize($command): string
+    public function serialize ($command): string
     {
         return serialize($command);
     }
 
-    public function unserialize(string $serialized)
+    public function unserialize (string $serialized)
     {
         return unserialize($serialized);
     }

src/Serializer/MessagePackCommandSerializer.php

Spacing +3 added lines, -3 removed lines

@@ -12,18 +12,18 @@
     private $packer;
     private $unpacker;
 
-    public function __construct(Packer $packer, BufferUnpacker $unpacker)
+    public function __construct (Packer $packer, BufferUnpacker $unpacker)
     {
         $this->packer = $packer;
         $this->unpacker = $unpacker;
     }
 
-    public function serialize($command): string
+    public function serialize ($command): string
     {
         return $this->packer->pack($command);
     }
 
-    public function unserialize(string $serialized)
+    public function unserialize (string $serialized)
     {
         return $this->unpacker->reset($serialized)->unpack();
     }

src/CommandHandler.php

Spacing +4 added lines, -4 removed lines

@@ -7,26 +7,26 @@
 
     private $implementation;
 
-    public function __construct(Implementation $implementation)
+    public function __construct (Implementation $implementation)
     {
         $this->implementation = $implementation;
     }
 
-    public function handleQueued(QueuedCommand $queuedCommand)
+    public function handleQueued (QueuedCommand $queuedCommand)
     {
         list($queueName, $id, $serialized) = $this->process($queuedCommand);
         $this->implementation->getQueueAdapter()
             ->queueCommand($queueName, $id, $serialized);
     }
 
-    public function handleScheduled(ScheduledCommand $scheduledCommand)
+    public function handleScheduled (ScheduledCommand $scheduledCommand)
     {
         list($queueName, $id, $serialized) = $this->process($scheduledCommand);
         $this->implementation->getSchedulerAdapter()
             ->scheduleCommand($queueName, $id, $serialized, $scheduledCommand->getDateTime());
     }
 
-    private function process(BusQueCommandInterface $command): array
+    private function process (BusQueCommandInterface $command): array
     {
         $baseCommand = $command->getCommand();
         $queueName = $this->implementation->getQueueResolver()