tidal / PEIP

src/Plugins/BasePlugin.php

Spacing +6 added lines, -6 removed lines

@@ -67,7 +67,7 @@ 
      */
     public function doCreateChannel($config, $defaultChannelClass, array $additionalArguments = [])
     {
-        $id = (string) $config['id'];
+        $id = (string)$config['id'];
         if ($id != '') {
             array_unshift($additionalArguments, $id);
             $channel = $this->buildAndModify($config, $additionalArguments, $defaultChannelClass);
@@ -95,7 +95,7 @@ 
         ];
         $defaultClass = $defaultClass ? $defaultClass : '\PEIP\Gateway\SimpleMessagingGateway';
         $gateway = $this->buildAndModify($config, $args, $defaultClass);
-        $id = (string) $config['id'];
+        $id = (string)$config['id'];
         $this->gateways[$id] = $gateway;
 
         return $gateway;
@@ -116,7 +116,7 @@ 
      */
     public function createRouter($config, $defaultClass = false)
     {
-        $resolver = $config['channel_resolver'] ? (string) $config['channel_resolver'] : $this->channelRegistry;
+        $resolver = $config['channel_resolver'] ? (string)$config['channel_resolver'] : $this->channelRegistry;
 
         return $this->buildAndModify($config, [
             $resolver,
@@ -211,8 +211,8 @@ 
      */
     public function createServiceActivator($config, $defaultClass = false)
     {
-        $method = (string) $config['method'];
-        $service = $this->context->getServiceProvider()->provideService((string) $config['ref']);
+        $method = (string)$config['method'];
+        $service = $this->context->getServiceProvider()->provideService((string)$config['ref']);
         if ($method && $service) {
             $args = $this->getReplyHandlerArguments($config);
             array_unshift($args, [
@@ -287,6 +287,6 @@ 
             ? $config[$type.'_channel']
             : $config['default_'.$type.'_channel'];
 
-        return $this->context->getServiceProvider()->provideService(trim((string) $channelName));
+        return $this->context->getServiceProvider()->provideService(trim((string)$channelName));
     }
 }

src/Channel/ChannelAdapter.php

Spacing +1 added lines, -1 removed lines

@@ -104,7 +104,7 @@
         $listners = $this->doGetListeners();
         if (!$this->hadListeners($name, $object)) {
             $res = false;
-        } else {
+        }else {
             $listners = $this->doGetListeners();
             $res = (boolean)count($listners[$object][$name]);
         }

src/Channel/PriorityChannel.php

Spacing +2 added lines, -2 removed lines

@@ -36,7 +36,7 @@ 
      */
     public function __construct($capacity = -1, $priorityHeader = null)
     {
-        $this->setCapacity((int) $capacity);
+        $this->setCapacity((int)$capacity);
         $this->queue = new SplPriorityQueue();
         if ($priorityHeader) {
             $this->priorityHeader = $priorityHeader;
@@ -52,7 +52,7 @@ 
     {
         if ($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()) {
             $this->queue->insert($message, $message->getHeader($this->priorityHeader));
-        } else {
+        }else {
             throw new \Exception('Not implemented yet.');
         }
     }

src/Channel/QueueChannel.php

Spacing +2 added lines, -2 removed lines

@@ -31,7 +31,7 @@ 
      */
     public function __construct($capacity = -1)
     {
-        $this->setCapacity((int) $capacity);
+        $this->setCapacity((int)$capacity);
         $this->queue = new SplQueue();
     }
 
@@ -70,7 +70,7 @@ 
     {
         if ($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()) {
             $this->queue->enqueque($message);
-        } else {
+        }else {
             throw new \Exception('Not implemented yet.');
         }
     }

src/Channel/PollableChannel.php

Spacing +1 added lines, -1 removed lines

@@ -104,7 +104,7 @@
         $listners = $this->doGetListeners();
         if (!$this->hadListeners($name, $object)) {
             $res = false;
-        } else {
+        }else {
             $listners = $this->doGetListeners();
             $res = (boolean)count($listners[$object][$name]);
         }

src/Pipe/FixedEventPipe.php

Spacing +1 added lines, -1 removed lines

@@ -104,7 +104,7 @@
         $listners = $this->doGetListeners();
         if (!$this->hadListeners($name, $object)) {
             $res = false;
-        } else {
+        }else {
             $listners = $this->doGetListeners();
             $res = (boolean)count($listners[$object][$name]);
         }

src/Pipe/Pipe.php

Spacing +2 added lines, -2 removed lines

@@ -103,7 +103,7 @@ 
         //if(\PEIP\Util\Test::assertMessage($message)){
             if ($this->getOutputChannel()) {
                 $this->getOutputChannel()->send($message);
-            } else {
+            }else {
                 $this->doSend($message);
             }
         //}
@@ -195,7 +195,7 @@ 
     public function command(\PEIP\INF\Message\Message $cmdMessage)
     {
         $this->doFireEvent(self::EVENT_PRE_COMMAND, [self::HEADER_MESSAGE => $cmdMessage]);
-        $commandName = trim((string) $cmdMessage->getHeader('COMMAND'));
+        $commandName = trim((string)$cmdMessage->getHeader('COMMAND'));
         if ($commandName != '' && array_key_exists($commandName, $this->commands)) {
             call_user_func($this->commands[$commandName], $cmdMessage->getContent());
         }

src/Message/TextMessage.php

Spacing +2 added lines, -2 removed lines

@@ -35,7 +35,7 @@ 
      */
     public function __construct($content, $title)
     {
-        $this->setContent((string) $content);
+        $this->setContent((string)$content);
     }
 
     /**
@@ -45,7 +45,7 @@ 
      */
     public function setTitle($title)
     {
-        $this->title = (string) $title;
+        $this->title = (string)$title;
     }
 
     /**

src/Message/GenericMessage.php

Spacing +3 added lines, -3 removed lines

@@ -82,7 +82,7 @@ 
      */
     public function getHeaders()
     {
-        return (array) $this->headers;
+        return (array)$this->headers;
     }
 
     /**
@@ -94,7 +94,7 @@ 
      */
     public function getHeader($name)
     {
-        $name = (string) $name;
+        $name = (string)$name;
 
         return isset($this->headers[$name]) ? $this->headers[$name] : null;
     }
@@ -139,7 +139,7 @@ 
     {
         $res = false;
         try {
-            $res = (string) $this->getContent();
+            $res = (string)$this->getContent();
         } catch (\Exception $e) {
             try {
                 $res = get_class($this->getContent());