tidal / PEIP

examples/Cafe/lib/messaging/CafeGateway.php

Indentation +7 added lines, -7 removed lines

@@ -4,13 +4,13 @@
 

 class CafeGateway extends SimpleMessagingGateway {

 

-	public function placeOrder(Order $order){

-		echo "\nCafe: place order #".$order->getOrderNumber();

-		$this->send($order);

-	}

+    public function placeOrder(Order $order){

+        echo "\nCafe: place order #".$order->getOrderNumber();

+        $this->send($order);

+    }

 	

-	public function receiveDelivery(){

-		return $this->receive();

-	}

+    public function receiveDelivery(){

+        return $this->receive();

+    }

 

 }

examples/Cafe/lib/messaging/DrinkAggregator.php

Indentation +28 added lines, -28 removed lines

@@ -4,38 +4,38 @@
 use PEIP\INF\Message\Message;

 

 class DrinkAggregator 

-	extends \PEIP\Pipe\Pipe {

+    extends \PEIP\Pipe\Pipe {

 

-	protected $orders = array();

-	protected $preparedDrinks = array();

+    protected $orders = array();

+    protected $preparedDrinks = array();

 	

-	public function __construct(Channel $inputChannel, Channel $outputChannel = NULL){

-		$this->setInputChannel($inputChannel);

-		if(is_object($outputChannel)){

-			$this->setOutputChannel($outputChannel);	

-		}

-		$this->registerCommand('ADD_ORDER', array($this, 'receiveOrder'));

-	}

+    public function __construct(Channel $inputChannel, Channel $outputChannel = NULL){

+        $this->setInputChannel($inputChannel);

+        if(is_object($outputChannel)){

+            $this->setOutputChannel($outputChannel);	

+        }

+        $this->registerCommand('ADD_ORDER', array($this, 'receiveOrder'));

+    }

 

-	protected function doReply(Message $message){

-		$drink = $message->getContent();

-		$nr = $drink->getOrderNumber();

-		if(!isset($this->preparedDrinks[$nr])){

-			$this->preparedDrinks[$nr] = array();

-		}

-		$this->preparedDrinks[$drink->getOrderNumber()][] = $drink;

-		if(isset($this->orders[$nr]) 

-			&& $this->orders[$nr]->getTotalCount() == count($this->preparedDrinks[$nr])){

-			$this->replyMessage($this->preparedDrinks[$nr]);

-			unset($this->preparedDrinks[$nr]);

-			echo PEIP_LINE_SEPARATOR.'DrinkAggregator : reply #'.$nr;	

-		}

-	}

+    protected function doReply(Message $message){

+        $drink = $message->getContent();

+        $nr = $drink->getOrderNumber();

+        if(!isset($this->preparedDrinks[$nr])){

+            $this->preparedDrinks[$nr] = array();

+        }

+        $this->preparedDrinks[$drink->getOrderNumber()][] = $drink;

+        if(isset($this->orders[$nr]) 

+            && $this->orders[$nr]->getTotalCount() == count($this->preparedDrinks[$nr])){

+            $this->replyMessage($this->preparedDrinks[$nr]);

+            unset($this->preparedDrinks[$nr]);

+            echo PEIP_LINE_SEPARATOR.'DrinkAggregator : reply #'.$nr;	

+        }

+    }

 

-	public function receiveOrder(Order $order){

-		echo PEIP_LINE_SEPARATOR.'DrinkAggregator: received Order';

-		$this->orders[$order->getOrderNumber()] = $order;	

-	}	

+    public function receiveOrder(Order $order){

+        echo PEIP_LINE_SEPARATOR.'DrinkAggregator: received Order';

+        $this->orders[$order->getOrderNumber()] = $order;	

+    }	

 	

 

 }

examples/Cafe/lib/messaging/DrinkRouter.php

Indentation +7 added lines, -7 removed lines

@@ -4,14 +4,14 @@
 use PEIP\INF\Message\Message;

 

 class DrinkRouter 

-	extends Router {

+    extends Router {

 	

-	protected function selectChannels(Message $message){

-		$order = $message->getContent();

-		$channelName = $order['iced']  ? 'coldDrinks' : 'hotDrinks';

-		echo PEIP_LINE_SEPARATOR."DrinkRouter: routed to channel: $channelName";

-		return $channelName;

-	}	

+    protected function selectChannels(Message $message){

+        $order = $message->getContent();

+        $channelName = $order['iced']  ? 'coldDrinks' : 'hotDrinks';

+        echo PEIP_LINE_SEPARATOR."DrinkRouter: routed to channel: $channelName";

+        return $channelName;

+    }	

 

 	

 }

examples/Cafe/lib/messaging/OrderSplitter.php

Indentation +15 added lines, -15 removed lines

@@ -5,20 +5,20 @@
 

 class OrderSplitter extends MessageSplitter {

 

-	public function split(Message $message){

-		$order = $message->getContent();

-		$orderItems = $order->getItems();

-		$items = array();

-		foreach($orderItems as $item){

-			$nr = $item['number'];

-			unset($item['number']);

-			$item['order'] = $order->getOrderNumber();

-			for($x = 0; $x < $nr; $x++){

-				$items[] = $item;	

-			}

-		}

-		echo PEIP_LINE_SEPARATOR."OrderSplitter: split order #: ".$order->getOrderNumber();

-		return $items;

-	}

+    public function split(Message $message){

+        $order = $message->getContent();

+        $orderItems = $order->getItems();

+        $items = array();

+        foreach($orderItems as $item){

+            $nr = $item['number'];

+            unset($item['number']);

+            $item['order'] = $order->getOrderNumber();

+            for($x = 0; $x < $nr; $x++){

+                $items[] = $item;	

+            }

+        }

+        echo PEIP_LINE_SEPARATOR."OrderSplitter: split order #: ".$order->getOrderNumber();

+        return $items;

+    }

 	

 }

examples/Cafe/lib/model/Cafe.php

Indentation +4 added lines, -4 removed lines

@@ -1,11 +1,11 @@
 <?php

 

 class Cafe 

-	extends \PEIP\Gateway\SimpleMessagingGateway {

+    extends \PEIP\Gateway\SimpleMessagingGateway {

 

-	public function placeOrder(Order $order){

-		return $this->sendAndReceive($order);	

-	}

+    public function placeOrder(Order $order){

+        return $this->sendAndReceive($order);	

+    }

 

 }

 

examples/HelloWorld/hello_world_scripted.php

Indentation +3 added lines, -3 removed lines

@@ -9,9 +9,9 @@
 // simple service class

 class HelloService {

 

-	public function greet($name){

-		return 'Hello '.$name;

-	}

+    public function greet($name){

+        return 'Hello '.$name;

+    }

 

 }