kaliop-uk / kueueingbundle-stomp

Adapter/Stomp/Client.php

Doc Comments +3 added lines

@@ -240,6 +240,9 @@
         }
     }
 
+    /**
+     * @param boolean $doHandle
+     */
     public function setHandleSignals($doHandle)
     {
         $this->dispatchSignals = $doHandle;

Spacing +8 added lines, -8 removed lines

@@ -21,7 +21,7 @@ 
      * @return boolean
      * @throws StompException
      */
-    public function connect ($username = '', $password = '')
+    public function connect($username = '', $password = '')
     {
         $this->_makeConnection();
         if ($username != '') {
@@ -30,7 +30,7 @@ 
         if ($password != '') {
             $this->_password = $password;
         }
-        $headers = array('login' => $this->_username , 'passcode' => $this->_password);
+        $headers = array('login' => $this->_username, 'passcode' => $this->_password);
         if ($this->clientId != null) {
             $headers["client-id"] = $this->clientId;
         }
@@ -66,7 +66,7 @@ 
      * @return boolean
      * @throws StompException
      */
-    public function subscribe ($destination, $properties = null, $sync = null)
+    public function subscribe($destination, $properties = null, $sync = null)
     {
         $headers = array('ack' => 'client');
         if ($this->brokerVendor == 'AMQ') {
@@ -108,7 +108,7 @@ 
      * @param Frame $stompFrame
      * @throws StompException
      */
-    protected function _writeFrame (Frame $stompFrame)
+    protected function _writeFrame(Frame $stompFrame)
     {
         if (!is_resource($this->_socket)) {
             throw new StompException('Socket connection hasn\'t been established');
@@ -131,7 +131,7 @@ 
      *
      * @return Frame False when no frame to read
      */
-    public function readFrame ()
+    public function readFrame()
     {
         if (!empty($this->_waitbuf)) {
             return array_shift($this->_waitbuf);
@@ -205,7 +205,7 @@ 
         $connect_errno = null;
         $connect_errstr = null;
 
-        while (! $connected && $att ++ < $this->_attempts) {
+        while (!$connected && $att++ < $this->_attempts) {
             if (isset($this->_params['randomize']) && $this->_params['randomize'] == 'true') {
                 $i = rand(0, count($this->_hosts) - 1);
             } else {
@@ -223,7 +223,7 @@ 
                 $this->_socket = null;
             }
 
-            $this->_socket = @fsockopen($scheme . '://' . $host, $port, $connect_errno, $connect_errstr, $this->_connect_timeout_seconds);
+            $this->_socket = @fsockopen($scheme.'://'.$host, $port, $connect_errno, $connect_errstr, $this->_connect_timeout_seconds);
 
             $this->maybeStopClient();
 
@@ -235,7 +235,7 @@ 
                 break;
             }
         }
-        if (! $connected) {
+        if (!$connected) {
             throw new StompException("Could not connect to a broker");
         }
     }

Adapter/Stomp/QueueManager.php

Unused Use Statements -1 removed lines

@@ -2,7 +2,6 @@
 
 namespace Kaliop\Queueing\Plugins\StompBundle\Adapter\Stomp;
 
-use Kaliop\QueueingBundle\Service\MessageProducer as BaseMessageProducer;
 use Symfony\Component\DependencyInjection\ContainerAwareInterface;
 use Symfony\Component\DependencyInjection\ContainerInterface;
 use InvalidArgumentException;

Spacing +1 added lines, -1 removed lines

@@ -39,7 +39,7 @@
         return array('list-configured');
     }
 
-    public function executeAction($action, array $arguments=array())
+    public function executeAction($action, array $arguments = array())
     {
         switch ($action) {
             case 'list-configured':

Adapter/Stomp/Consumer.php

Spacing +7 added lines, -7 removed lines

@@ -59,7 +59,7 @@ 
 
     protected function setClientId()
     {
-        $newId = $this->subscriptionName . ($this->label != '' ? '_' . $this->label : '');
+        $newId = $this->subscriptionName.($this->label != '' ? '_'.$this->label : '');
         if ($newId != $this->client->clientId) {
             $this->client->clientId = $newId;
             $this->subscribed = false;
@@ -87,7 +87,7 @@ 
      */
     public function setCallback($callback)
     {
-        if (! $callback instanceof \Kaliop\QueueingBundle\Queue\MessageConsumerInterface) {
+        if (!$callback instanceof \Kaliop\QueueingBundle\Queue\MessageConsumerInterface) {
             throw new \RuntimeException('Can not set callback to Stomp Consumer, as it is not a MessageConsumerInterface');
         }
         $this->callback = $callback;
@@ -111,7 +111,7 @@ 
      * @param int $timeout seconds
      * @return nothing
      */
-    public function consume($amount, $timeout=0)
+    public function consume($amount, $timeout = 0)
     {
         $toConsume = $amount;
         if ($timeout > 0) {
@@ -123,7 +123,7 @@ 
 
         $this->subscribe();
 
-        while(true) {
+        while (true) {
             if ($timeout > 0) {
                 $this->client->setReadTimeout($remaining);
             }
@@ -131,7 +131,7 @@ 
             $message = $this->client->readFrame();
 
             if ($message !== false) {
-                switch($message->command)
+                switch ($message->command)
                 {
                     case 'MESSAGE':
                         $this->client->ack($message);
@@ -160,11 +160,11 @@ 
         }
     }
 
-    protected function getClientProperties(array $additionalProperties = array(), $command='')
+    protected function getClientProperties(array $additionalProperties = array(), $command = '')
     {
         $result = $additionalProperties;
 
-        switch($command)
+        switch ($command)
         {
             case 'SUBSCRIBE';
                 //$result = array_merge(array('persistent' => 'true'), $result);

Adapter/Stomp/Producer.php

Spacing +3 added lines, -3 removed lines

@@ -33,7 +33,7 @@ 
     public function publish($msgBody, $routingKey = '', $additionalProperties = array())
     {
         $this->connect();
-        if (! $this->client->send(
+        if (!$this->client->send(
             $this->getFullQueueName($routingKey),
             $msgBody,
             $this->getClientProperties($additionalProperties),
@@ -51,8 +51,8 @@ 
     {
         $this->connect();
 
-        foreach($messages as $message) {
-            if (! $this->client->send(
+        foreach ($messages as $message) {
+            if (!$this->client->send(
                 $this->getFullQueueName(@$message['routingKey']),
                 $message['msgBody'],
                 $this->getClientProperties(@$message['additionalProperties']),

Adapter/Stomp/Stomp.php

Spacing +3 added lines, -3 removed lines

@@ -84,15 +84,15 @@
     {
         $queueName = $this->stompQueueName;
         if ($routingKey != '') {
-            switch($this->client->brokerVendor) {
+            switch ($this->client->brokerVendor) {
                 case 'Apollo':
                     $routingKey = str_replace('#', '**', $routingKey);
-                    $queueName = rtrim($queueName, '.') . '.' . ltrim($routingKey, '.');
+                    $queueName = rtrim($queueName, '.').'.'.ltrim($routingKey, '.');
                     break;
                 case 'AMQ':
                 default:
                     $routingKey = str_replace('#', '>', $routingKey);
-                    $queueName = rtrim($queueName, '.') . '.' . ltrim($routingKey, '.');
+                    $queueName = rtrim($queueName, '.').'.'.ltrim($routingKey, '.');
             }
         }
         return $queueName;

Adapter/Stomp/Driver.php

Spacing +1 added lines, -1 removed lines

@@ -117,7 +117,7 @@
      * @param string $routingKey
      * @return Consumer
      */
-    public function createConsumer($queueName, $queueDestination, $connectionId, $subscriptionName, $callback=null, $routingKey=null)
+    public function createConsumer($queueName, $queueDestination, $connectionId, $subscriptionName, $callback = null, $routingKey = null)
     {
         $class = $this->container->getParameter('kaliop_queueing.stomp.consumer.class');
         $consumer = new $class($this->getConnectionConfig($connectionId));