View GitHub Repository PEIP

Schedule Inspection
Subscribe
Completed
Push — v1.ns ( 31020d...499c60 )
by Timo
04:35 queued 01:07
created
Status
Category
Toggle Patches
src/Message/TextMessage.php 1 patch
Spacing   +4 added lines, -4 removed lines patch added patch discarded remove patch 
@@ -34,7 +34,7 @@  discard block
 
 block discarded – undo
34 34 
      * @param $title
35 35 
      * @return
36 36 
      */
37 
-    public function __construct($content, $title){
37 
+    public function __construct($content, $title) {
38 38 
         $this->setContent((string)$content);
39 39 
     }
40 40 
 

@@ -44,7 +44,7 @@  discard block
 
 block discarded – undo
44 44 
      * @param $title
45 45 
      * @return
46 46 
      */
47 
-    public function setTitle($title){
47 
+    public function setTitle($title) {
48 48 
         $this->title = (string)$title;
49 49 
     }
50 50 
 

@@ -53,7 +53,7 @@  discard block
 
 block discarded – undo
53 53 
      * @access public
54 54 
      * @return
55 55 
      */
56 
-    public function getTitle(){
56 
+    public function getTitle() {
57 57 
         return $this->title;
58 58 
     }
59 59 
 

@@ -67,7 +67,7 @@  discard block
 
 block discarded – undo
67 67 
      * @param string $name the name of the header
68 68 
      * @return boolean wether the header is set
69 69 
      */
70 
-    public static function build(array $arguments = array()){
70 
+    public static function build(array $arguments = array()) {
71 71 
         return GenericBuilder::getInstance('\PEIP\Message\StringMessage')->build($arguments);
72 72 
     }
73 73
Please login to merge, or discard this patch.
src/Message/ErrorMessage.php 1 patch
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch 
@@ -36,7 +36,7 @@
 
 block discarded – undo
36 36 
      * @param $headers
37 37 
      * @return
38 38 
      */
39 
-    public function __construct(\Exception $payload, array $headers = array()){
39 
+    public function __construct(\Exception $payload, array $headers = array()) {
40 40 
         $this->payload = $payload;
41 41 
         $this->headers = $headers;
42 42 
     }
Please login to merge, or discard this patch.
src/Channel/QueueChannel.php 1 patch
Spacing   +7 added lines, -7 removed lines patch added patch discarded remove patch 
@@ -37,7 +37,7 @@  discard block
 
 block discarded – undo
37 37 
      * @param $capacity
38 38 
      * @return
39 39 
      */
40 
-    public function __construct($capacity = -1){
40 
+    public function __construct($capacity = -1) {
41 41 
         $this->setCapacity((int)$capacity);
42 42 
         $this->queue = new SplQueue();
43 43 
     }   

@@ -47,7 +47,7 @@  discard block
 
 block discarded – undo
47 47 
      * @access public
48 48 
      * @return
49 49 
      */
50 
-    public function getMessageCount(){
50 
+    public function getMessageCount() {
51 51 
         return count($this->messages);
52 52 
     }
53 53 
 

@@ -56,7 +56,7 @@  discard block
 
 block discarded – undo
56 56 
      * @access public
57 57 
      * @return
58 58 
      */
59 
-    public function getCapacity(){
59 
+    public function getCapacity() {
60 60 
         return $this->capacity;
61 61 
     }
62 62 
 

@@ -66,7 +66,7 @@  discard block
 
 block discarded – undo
66 66 
      * @param $capacity
67 67 
      * @return
68 68 
      */
69 
-    public function setCapacity($capacity){
69 
+    public function setCapacity($capacity) {
70 70 
         $this->capacity = $capacity;
71 71 
     }
72 72 
 

@@ -76,10 +76,10 @@  discard block
 
 block discarded – undo
76 76 
      * @param $message
77 77 
      * @return
78 78 
      */
79 
-    protected function doSend(\PEIP\INF\Message\Message $message){
80 
-        if($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()){
79 
+    protected function doSend(\PEIP\INF\Message\Message $message) {
80 
+        if ($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()) {
81 81 
             $this->queue->enqueque($message);
82 
-        }else{
82 
+        }else {
83 83 
             throw new \Exception('Not implemented yet.');
84 84 
         }
85 85 
     }
Please login to merge, or discard this patch.
src/Channel/PriorityChannel.php 1 patch
Spacing   +5 added lines, -5 removed lines patch added patch discarded remove patch 
@@ -37,10 +37,10 @@  discard block
 
 block discarded – undo
37 37 
      * @param $priorityHeader
38 38 
      * @return
39 39 
      */
40 
-    public function __construct($capacity = -1, $priorityHeader = NULL){
40 
+    public function __construct($capacity = -1, $priorityHeader = NULL) {
41 41 
         $this->setCapacity((int)$capacity);
42 42 
         $this->queue = new SplPriorityQueue();
43 
-        if($priorityHeader){
43 
+        if ($priorityHeader) {
44 44 
             $this->priorityHeader = $priorityHeader;
45 45 
         }
46 46 
     }   

@@ -51,10 +51,10 @@  discard block
 
 block discarded – undo
51 51 
      * @param $message
52 52 
      * @return
53 53 
      */
54 
-    protected function doSend(\PEIP\INF\Message\Message $message){
55 
-        if($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()){
54 
+    protected function doSend(\PEIP\INF\Message\Message $message) {
55 
+        if ($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()) {
56 56 
             $this->queue->insert($message, $message->getHeader($this->priorityHeader));
57 
-        }else{
57 
+        }else {
58 58 
             throw new \Exception('Not implemented yet.');
59 59 
         }
60 60 
     }
Please login to merge, or discard this patch.
src/Channel/ChannelRegistry.php 1 patch
Spacing   +4 added lines, -4 removed lines patch added patch discarded remove patch 
@@ -33,7 +33,7 @@  discard block
 
 block discarded – undo
33 33 
      * @param $name
34 34 
      * @return
35 35 
      */
36 
-    public static function getInstance(){
36 
+    public static function getInstance() {
37 37 
         return self::$instance ? self::$instance : self::$instance = new ChannelRegistry;
38 38 
     }
39 39 
     

@@ -43,7 +43,7 @@  discard block
 
 block discarded – undo
43 43 
      * @param $channel
44 44 
      * @return
45 45 
      */
46 
-    public function register($channel){
46 
+    public function register($channel) {
47 47 
         $this->channels[$channel->getName()] = $channel;
48 48 
     }
49 49 
 

@@ -55,7 +55,7 @@  discard block
 
 block discarded – undo
55 55 
      * @param $name
56 56 
      * @return
57 57 
      */
58 
-    public function get($name){
58 
+    public function get($name) {
59 59 
         return $this->channels[$name];
60 60 
     }
61 61 
 

@@ -65,7 +65,7 @@  discard block
 
 block discarded – undo
65 65 
      * @param $channelName
66 66 
      * @return
67 67 
      */
68 
-    public function resolveChannelName($channelName){
68 
+    public function resolveChannelName($channelName) {
69 69 
         return $this->get($channelName);
70 70 
     }
71 71
Please login to merge, or discard this patch.
src/Channel/PollableChannel.php 1 patch
Spacing   +12 added lines, -12 removed lines patch added patch discarded remove patch 
@@ -41,7 +41,7 @@  discard block
 
 block discarded – undo
41 41 
      * @param \PEIP\INF\Message\Message $message the message to send
42 42 
      * @return
43 43 
      */
44 
-    protected function doSend(\PEIP\INF\Message\Message $message){
44 
+    protected function doSend(\PEIP\INF\Message\Message $message) {
45 45 
         $this->messages[] = $message;
46 46 
         return true;
47 47 
     }

@@ -55,18 +55,18 @@  discard block
 
 block discarded – undo
55 55 
      * @param integer $timeout timout for receiving a message
56 56 
      * @return
57 57 
      */
58 
-    public function receive($timeout = 0){
58 
+    public function receive($timeout = 0) {
59 59 
         $this->doFireEvent(self::EVENT_PRE_RECEIVE);
60 60 
         $message = NULL;
61 
-        if($timeout == 0){
61 
+        if ($timeout == 0) {
62 62 
             $message = $this->getMessage();
63 
-        }elseif($timeout < 0){
64 
-            while(!$message = $this->getMessage()){
63 
+        }elseif ($timeout < 0) {
64 
+            while (!$message = $this->getMessage()) {
65 65
66 66 
             }
67 
-        }else{
67 
+        }else {
68 68 
             $time = time() + $timeout;
69 
-            while(($time > time()) && !$message = $this->getMessage()){
69 
+            while (($time > time()) && !$message = $this->getMessage()) {
70 70
71 71 
             }
72 72 
         }

@@ -84,7 +84,7 @@  discard block
 
 block discarded – undo
84 84 
      * @access protected
85 85 
      * @return \PEIP\INF\Message\Message message from top of the message stack
86 86 
      */
87 
-    protected function getMessage(){
87 
+    protected function getMessage() {
88 88 
         return array_shift($this->messages);
89 89 
     }
90 90 
        

@@ -94,7 +94,7 @@  discard block
 
 block discarded – undo
94 94 
      * @access public
95 95 
      * @return
96 96 
      */
97 
-    public function clear(){
97 
+    public function clear() {
98 98 
         $this->messages = array();
99 99 
     }
100 100 
         

@@ -105,9 +105,9 @@  discard block
 
 block discarded – undo
105 105 
      * @param \PEIP\INF\Message\Message_Selector $selector the selector to accept messages
106 106 
      * @return array accepted messages
107 107 
      */
108 
-    public function purge(\PEIP\INF\Selector\MessageSelector $selector){
109 
-        foreach($this->messages as $key=>$message){
110 
-            if(!$selector->acceptMessage($message)){
108 
+    public function purge(\PEIP\INF\Selector\MessageSelector $selector) {
109 
+        foreach ($this->messages as $key=>$message) {
110 
+            if (!$selector->acceptMessage($message)) {
111 111 
                 unset($this->messages[$key]);
112 112 
             }
113 113 
         }
Please login to merge, or discard this patch.
src/Channel/MessageChannel.php 1 patch
Spacing   +2 added lines, -2 removed lines patch added patch discarded remove patch 
@@ -28,7 +28,7 @@  discard block
 
 block discarded – undo
28 28 
      * @access public
29 29 
      * @return
30 30 
      */
31 
-    public function getName(){
31 
+    public function getName() {
32 32
33 33 
     }
34 34 
 

@@ -40,7 +40,7 @@  discard block
 
 block discarded – undo
40 40 
      * @param $timeout
41 41 
      * @return
42 42 
      */
43 
-    public function send(\PEIP\INF\Message\Message $message, $timeout = -1){
43 
+    public function send(\PEIP\INF\Message\Message $message, $timeout = -1) {
44 44
45 45 
     }
46 46
Please login to merge, or discard this patch.
src/Channel/DirectChannel.php 1 patch
Spacing   +3 added lines, -3 removed lines patch added patch discarded remove patch 
@@ -36,7 +36,7 @@  discard block
 
 block discarded – undo
36 36 
      * @param $timeout
37 37 
      * @return
38 38 
      */
39 
-    public function send(\PEIP\INF\Message\Message $message, $timeout = -1){
39 
+    public function send(\PEIP\INF\Message\Message $message, $timeout = -1) {
40 40
41 41 
         $sent = $this->doSend($message);
42 42 
 

@@ -49,7 +49,7 @@  discard block
 
 block discarded – undo
49 49 
      * @param $message
50 50 
      * @return
51 51 
      */
52 
-    protected function doSend(\PEIP\INF\Message\Message $message){
52 
+    protected function doSend(\PEIP\INF\Message\Message $message) {
53 53 
         $this->getMessageDispatcher()->notify($message);
54 54 
         return true;
55 55 
     }

@@ -59,7 +59,7 @@  discard block
 
 block discarded – undo
59 59 
      * @access public
60 60 
      * @return
61 61 
      */
62 
-    public function getMessageDispatcher(){
62 
+    public function getMessageDispatcher() {
63 63 
         return isset($this->dispatcher) ? $this->dispatcher : $this->dispatcher = new IteratingDispatcher;
64 64 
     }
65 65
Please login to merge, or discard this patch.
src/Channel/PublishSubscribeChannel.php 1 patch
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch 
@@ -37,7 +37,7 @@
 
 block discarded – undo
37 37 
      * @param $message
38 38 
      * @return
39 39 
      */
40 
-    protected function doSend(\PEIP\INF\Message\Message $message){
40 
+    protected function doSend(\PEIP\INF\Message\Message $message) {
41 41 
         $this->doFireEvent('prePublish', array('MESSAGE'=>$message));
42 42 
         $this->getMessageDispatcher()->notify($message);
43 43 
         $this->doFireEvent('postPublish', array('MESSAGE'=>$message));
Please login to merge, or discard this patch.