tidal / PEIP

examples/Cafe/example.php

Spacing +2 added lines, -2 removed lines

@@ -44,7 +44,7 @@ 
  */

 

 

-if($cafe){

+if ($cafe) {

 

 	for ($i = 1; $i <= 10; $i++) {

        	// create and place orders

@@ -57,7 +57,7 @@ 
                 var_dump($drinks);

     	}	

 

-}else{

+}else {

 	throw new RuntimeException('Could not get CafeGateway');

 }

 

examples/Cafe/misc/bootstrap.php

Spacing +2 added lines, -2 removed lines

@@ -2,11 +2,11 @@
 

 require_once(dirname(__FILE__).'/../../../misc/bootstrap.php');

 

-foreach (glob(realpath(dirname(__FILE__)."/../lib/model/")."/*.php") as $filename){

+foreach (glob(realpath(dirname(__FILE__)."/../lib/model/")."/*.php") as $filename) {

     require_once $filename;

 }

 

-foreach (glob(realpath(dirname(__FILE__)."/../lib/messaging/")."/*.php") as $filename){

+foreach (glob(realpath(dirname(__FILE__)."/../lib/messaging/")."/*.php") as $filename) {

     require_once $filename;

 }

 

examples/Cafe/lib/messaging/CafeGateway.php

Spacing +2 added lines, -2 removed lines

@@ -4,12 +4,12 @@
 

 class CafeGateway extends SimpleMessagingGateway {

 

-	public function placeOrder(Order $order){

+	public function placeOrder(Order $order) {

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

 		$this->send($order);

 	}

 	

-	public function receiveDelivery(){

+	public function receiveDelivery() {

 		return $this->receive();

 	}

 

examples/Cafe/lib/messaging/DrinkAggregator.php

Spacing +7 added lines, -7 removed lines

@@ -9,30 +9,30 @@
 	protected $orders = array();

 	protected $preparedDrinks = array();

 	

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

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

 		$this->setInputChannel($inputChannel);

-		if(is_object($outputChannel)){

+		if (is_object($outputChannel)) {

 			$this->setOutputChannel($outputChannel);	

 		}

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

 	}

 

-	protected function doReply(Message $message){

+	protected function doReply(Message $message) {

 		$drink = $message->getContent();

 		$nr = $drink->getOrderNumber();

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

+		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])){

+		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){

+	public function receiveOrder(Order $order) {

 		echo PEIP_LINE_SEPARATOR.'DrinkAggregator: received Order';

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

 	}	

examples/Cafe/lib/messaging/DrinkRouter.php

Spacing +2 added lines, -2 removed lines

@@ -6,9 +6,9 @@
 class DrinkRouter 

 	extends Router {

 	

-	protected function selectChannels(Message $message){

+	protected function selectChannels(Message $message) {

 		$order = $message->getContent();

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

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

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

 		return $channelName;

 	}	

examples/Cafe/lib/messaging/OrderSplitter.php

Spacing +3 added lines, -3 removed lines

@@ -5,15 +5,15 @@
 

 class OrderSplitter extends MessageSplitter {

 

-	public function split(Message $message){

+	public function split(Message $message) {

 		$order = $message->getContent();

 		$orderItems = $order->getItems();

 		$items = array();

-		foreach($orderItems as $item){

+		foreach ($orderItems as $item) {

 			$nr = $item['number'];

 			unset($item['number']);

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

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

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

 				$items[] = $item;	

 			}

 		}

examples/Cafe/lib/model/Cafe.php

Spacing +1 added lines, -1 removed lines

@@ -3,7 +3,7 @@
 class Cafe 

 	extends \PEIP\Gateway\SimpleMessagingGateway {

 

-	public function placeOrder(Order $order){

+	public function placeOrder(Order $order) {

 		return $this->sendAndReceive($order);	

 	}

 

examples/HelloWorld/hello_world_scripted.php

Spacing +1 added lines, -1 removed lines

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

 class HelloService {

 

-	public function greet($name){

+	public function greet($name) {

 		return 'Hello '.$name;

 	}

 

src/Factory/DedicatedFactory.php

Spacing +5 added lines, -5 removed lines

@@ -38,16 +38,16 @@ 
      * @param $parameters 
      * @return 
      */
-    protected function __construct($callable ,array $parameters = array()){
+    protected function __construct($callable, array $parameters = array()) {
         $this->callable = $callable;
         $this->setParameters($parameters);
     }
 
-    public static function getfromClass($class, array $parameters = array()){
+    public static function getfromClass($class, array $parameters = array()) {
         return new DedicatedFactory(array($class, '__construct'), $parameters); 
     } 
 
-    public static function getfromCallable($callable, array $parameters = array()){
+    public static function getfromCallable($callable, array $parameters = array()) {
         return new DedicatedFactory($callable, $parameters); 
     } 
     
@@ -57,7 +57,7 @@ 
      * @param $arguments 
      * @return 
      */
-    public function build(array $arguments = array()){
+    public function build(array $arguments = array()) {
         $arguments = count($arguments) > 0 ? $arguments : $this->getParameters();
         return (is_array($this->callable) && $this->callable[1] == '__construct') 
             ? GenericBuilder::GetInstance($this->callable[0])->build($arguments) 
@@ -70,7 +70,7 @@ 
      * @param $method 
      * @return 
      */
-    public function setConstructor($method){
+    public function setConstructor($method) {
         $this->constructor = (string)$method;
         return $this;
     }