Merge pull request repejota#16 from repejota/feature/15

repejota · repejota · commit 510d29f01dfe · 2015-07-21T21:52:21.000+02:00
Fixed repejota#15
diff --git a/src/Connection.php b/src/Connection.php
@@ -204,8 +204,7 @@ public function ping()
     public function publish($subject, $payload)
     {
         $msg = 'PUB '.$subject.' '.strlen($payload);
-        $this->send($msg);
-        $this->send($payload);
+        $this->send($msg . "\r\n" . $payload);
         $this->pubs += 1;
     }
 

Original file line number	Diff line number	Diff line change
`@@ -204,8 +204,7 @@ public function ping()`
`204`	`204`	`public function publish($subject, $payload)`
`205`	`205`	`{`
`206`	`206`	`$msg = 'PUB '.$subject.' '.strlen($payload);`
`207`		`- $this->send($msg);`
`208`		`- $this->send($payload);`
	`207`	`+ $this->send($msg . "\r\n" . $payload);`
`209`	`208`	`$this->pubs += 1;`
`210`	`209`	`}`
`211`	`210`