tidal / PEIP

src/Plugins/BasePlugin.php

Spacing +19 added lines, -19 removed lines

@@ -42,7 +42,7 @@ 
      * @param object $config configuration object for the pollable channel.
      * @return \PEIP\INF\Channel\Channel the created pollable channel instance
      */
-    public function createChannel($config){
+    public function createChannel($config) {
         return $this->doCreateChannel($config, '\PEIP\Channel\PollableChannel');
     }
 
@@ -54,7 +54,7 @@ 
      * @param object $config configuration object for the subscribable channel.
      * @return \PEIP\INF\Channel\Channel the created subscribable channel instance
      */
-    public function createSubscribableChannel($config){
+    public function createSubscribableChannel($config) {
         return $this->doCreateChannel($config, '\PEIP\Channel\PublishSubscribeChannel');
     }
 
@@ -67,9 +67,9 @@ 
      * @param $additionalArguments additional arguments for the channel constructor (without first arg = id)
      * @return \PEIP\INF\Channel\Channel the created channel instance
      */
-    public function doCreateChannel($config, $defaultChannelClass, array $additionalArguments = array()){
+    public function doCreateChannel($config, $defaultChannelClass, array $additionalArguments = array()) {
         $id = (string)$config['id'];
-        if($id != ''){
+        if ($id != '') {
             array_unshift($additionalArguments, $id);
             $channel = $this->buildAndModify($config, $additionalArguments, $defaultChannelClass);
             //$this->channelRegistry->register($channel);
@@ -87,7 +87,7 @@ 
      * @param string $defaultClass the class to use if none is set in config.
      * @return object the gateway instance
      */
-    public function createGateway($config, $defaultClass = false){
+    public function createGateway($config, $defaultClass = false) {
         $args = array(
             $this->getRequestChannel($config),
             $this->getReplyChannel($config)
@@ -111,7 +111,7 @@ 
      * @param string $defaultClass the class to use if none is set in config.
      * @return object the router instance
      */
-    public function createRouter($config, $defaultClass = false){
+    public function createRouter($config, $defaultClass = false) {
         $resolver = $config['channel_resolver'] ? (string)$config['channel_resolver'] : $this->channelRegistry;
         return $this->buildAndModify($config, array(
             $resolver,
@@ -128,7 +128,7 @@ 
      * @param object $config configuration object for the splitter.
      * @return object the splitter instance
      */
-    public function createSplitter($config){
+    public function createSplitter($config) {
         return $this->createReplyMessageHandler($config);
     }
 
@@ -141,7 +141,7 @@ 
      * @param object $config configuration object for the transformer.
      * @return object the transformer instance
      */
-    public function createTransformer($config){
+    public function createTransformer($config) {
         return $this->createReplyMessageHandler($config);
     }
 
@@ -154,7 +154,7 @@ 
      * @param object $config configuration object for the aggregator.
      * @return object the aggregator instance
      */
-    public function createAggregator($config){
+    public function createAggregator($config) {
         return $this->createReplyMessageHandler($config);
     }
 
@@ -167,7 +167,7 @@ 
      * @param object $config configuration object for the wiretap.
      * @return object the wiretap instance
      */
-    public function createWiretap($config){
+    public function createWiretap($config) {
         return $this->createReplyMessageHandler($config, '\PEIP\Listener\Wiretap');
     }
 
@@ -180,7 +180,7 @@ 
      * @param string $defaultClass the class to use if none is set in config.
      * @return object the reply-message-handler instance
      */
-    public function createReplyMessageHandler($config, $defaultClass = false){
+    public function createReplyMessageHandler($config, $defaultClass = false) {
         return $this->buildAndModify($config, $this->getReplyHandlerArguments($config), $defaultClass);
     }
 
@@ -193,12 +193,12 @@ 
      * @param string $defaultClass the class to use if none is set in config.
      * @return object the service-activator instance
      */
-    public function createServiceActivator($config, $defaultClass = false){
+    public function createServiceActivator($config, $defaultClass = false) {
         $method = (string)$config['method'];
         $service = $this->context->getServiceProvider()->provideService((string)$config['ref']);
-        if($method && $service){
+        if ($method && $service) {
             $args = $this->getReplyHandlerArguments($config);
-            array_unshift($args,array(
+            array_unshift($args, array(
                 $service,
                 $method
             ));
@@ -215,12 +215,12 @@ 
      * @param object $config configuration object to create arguments from.
      * @return mixed build arguments
      */
-    protected function getReplyHandlerArguments($config){
+    protected function getReplyHandlerArguments($config) {
         $args = array(
             $this->doGetChannel('input', $config),
             $this->doGetChannel('output', $config)
         );
-        if($args[0] == NULL){
+        if ($args[0] == NULL) {
             throw new \RuntimeException('Could not receive input channel.');
         }
         return $args;
@@ -235,7 +235,7 @@ 
      * @param object $config configuration object to return request-channel from.
      * @return \PEIP\INF\Channel\Channel request-channel
      */
-    protected function getRequestChannel($config){
+    protected function getRequestChannel($config) {
         return $this->doGetChannel('request', $config);
     }
 
@@ -248,7 +248,7 @@ 
      * @param object $config configuration object to return reply-channel from.
      * @return \PEIP\INF\Channel\Channel reply-channel
      */
-    protected function getReplyChannel($config){
+    protected function getReplyChannel($config) {
         return $this->doGetChannel('reply', $config);
     }
 
@@ -261,7 +261,7 @@ 
      * @param object $config configuration object to return channel from.
      * @return \PEIP\INF\Channel\Channel reply-channel
      */
-    public function doGetChannel($type, $config){
+    public function doGetChannel($type, $config) {
         $channelName = isset($config[$type."_channel"])
             ? $config[$type."_channel"]
             : $config["default_".$type."_channel"];