pheanstalk / pheanstalk

src/Command/WatchCommand.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
 {
     public function getCommandLine(): string
     {
-        return 'watch ' . $this->tube;
+        return 'watch '.$this->tube;
     }
 
     public function parseResponse(string $responseLine, ?string $responseData): ArrayResponse

src/Command/PauseTubeCommand.php

Spacing +1 added lines, -1 removed lines

@@ -49,7 +49,7 @@
         } elseif ($responseLine == ResponseInterface::RESPONSE_PAUSED) {
             return $this->createResponse(ResponseInterface::RESPONSE_PAUSED);
         } else {
-            throw new Exception('Unhandled response: "' . $responseLine . '"');
+            throw new Exception('Unhandled response: "'.$responseLine.'"');
         }
     }
 }

src/Command/KickCommand.php

Spacing +1 added lines, -1 removed lines

@@ -26,7 +26,7 @@
 
     public function getCommandLine(): string
     {
-        return 'kick ' . $this->max;
+        return 'kick '.$this->max;
     }
 
     /* (non-phpdoc)

src/Command/KickJobCommand.php

Spacing +2 added lines, -2 removed lines

@@ -23,7 +23,7 @@ 
 {
     public function getCommandLine(): string
     {
-        return 'kick-job ' . $this->jobId;
+        return 'kick-job '.$this->jobId;
     }
 
     /* (non-phpdoc)
@@ -40,7 +40,7 @@ 
         } elseif ($responseLine == ResponseInterface::RESPONSE_KICKED) {
             return $this->createResponse(ResponseInterface::RESPONSE_KICKED);
         } else {
-            throw new Exception('Unhandled response: ' . $responseLine);
+            throw new Exception('Unhandled response: '.$responseLine);
         }
     }
 }

src/Command/DeleteCommand.php

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
 {
     public function getCommandLine(): string
     {
-        return 'delete ' . $this->jobId;
+        return 'delete '.$this->jobId;
     }
 
     public function parseResponse(string $responseLine, ?string $responseData): ArrayResponse

src/Connection.php

Spacing +2 added lines, -2 removed lines

@@ -73,10 +73,10 @@
     {
         $socket = $this->getSocket();
 
-        $to_send = $command->getCommandLine() . self::CRLF;
+        $to_send = $command->getCommandLine().self::CRLF;
 
         if ($command->hasData()) {
-            $to_send .= $command->getData() . self::CRLF;
+            $to_send .= $command->getData().self::CRLF;
         }
 
         $socket->write($to_send);

src/Command/IgnoreCommand.php

Spacing +3 added lines, -3 removed lines

@@ -17,7 +17,7 @@ 
 {
     public function getCommandLine(): string
     {
-        return 'ignore ' . $this->tube;
+        return 'ignore '.$this->tube;
     }
 
     public function parseResponse(string $responseLine, ?string $responseData): ArrayResponse
@@ -28,10 +28,10 @@ 
             ]);
         } elseif ($responseLine == ResponseInterface::RESPONSE_NOT_IGNORED) {
             throw new Exception\ServerException(
-                $responseLine . ': cannot ignore last tube in watchlist'
+                $responseLine.': cannot ignore last tube in watchlist'
             );
         } else {
-            throw new Exception('Unhandled response: ' . $responseLine);
+            throw new Exception('Unhandled response: '.$responseLine);
         }
     }
 }

src/Command/BuryCommand.php

Spacing +1 added lines, -1 removed lines

@@ -44,7 +44,7 @@
         } elseif ($responseLine == ResponseInterface::RESPONSE_BURIED) {
             return $this->createResponse(ResponseInterface::RESPONSE_BURIED);
         } else {
-            throw new Exception('Unhandled response: ' . $responseLine);
+            throw new Exception('Unhandled response: '.$responseLine);
         }
     }
 }

src/Command/UseCommand.php

Spacing +1 added lines, -1 removed lines

@@ -18,7 +18,7 @@
 {
     public function getCommandLine(): string
     {
-        return 'use ' . $this->tube;
+        return 'use '.$this->tube;
     }
 
     public function parseResponse(string $responseLine, ?string $responseData): ArrayResponse