Merge branch 'release/0.8.3'

Author: repejota

.travis.yml

@@ -3,7 +3,6 @@ services:
   - docker
 language: php
 php:
-  - 5.5
   - 5.6
   - 7
   - 7.1

README.md

@@ -21,7 +21,7 @@ A PHP client for the [NATS messaging system](https://nats.io).
 Requirements
 ------------
 
-* php 5.5+
+* php 5.6+
 * [nats](https://github.com/derekcollison/nats) or [gnatsd](https://github.com/apcera/gnatsd)
 
 
@@ -58,30 +58,93 @@ Composer will download all the dependencies defined in composer.json, and prepar
 $client = new \Nats\Connection();
 $client->connect();
 
-# Simple Publisher
-$client->publish("foo", "foo bar");
+// Publish Subscribe
 
-# Simple Subscriber
-$callback = function($payload)
-{
-    printf("Data: %s\r\n", $payload);
-};
-$client->subscribe("foo", $callback);
+// Simple Subscriber.
+$client->subscribe(
+    'foo',
+    function ($message) {
+        printf("Data: %s\r\n", $message->getBody());
+    }
+);
 
-# Request
-$client->request('sayhello', 'Marty McFly', function ($response) {
-    echo $response->getBody();
-});
+// Simple Publisher.
+$client->publish('foo', 'Marty McFly');
 
-# Responding to requests
-$sid = $client->subscribe("sayhello", function ($res) {
-    $res->reply("Hello, " . $res->getBody() . " !!!");
-});
+// Wait for 1 message.
+$client->wait(1);
 
+// Request Response
+
+// Responding to requests.
+$sid = $client->subscribe(
+    'sayhello',
+    function ($message) {
+        $message->reply('Reply: Hello, '.$message->getBody().' !!!');
+    }
+);
+
+// Request.
+$client->request(
+    'sayhello',
+    'Marty McFly',
+    function ($message) {
+        echo $message->getBody();
+    }
+);
+```
 
+### Encoded Connections
 
-# Wait for 1 message
+```php
+$encoder = new \Nats\Encoders\JSONEncoder();
+$options = new \Nats\ConnectionOptions();
+$client = new \Nats\EncodedConnection($options, $encoder);
+$client->connect();
+
+// Publish Subscribe
+
+// Simple Subscriber.
+$client->subscribe(
+    'foo',
+    function ($payload) {
+        printf("Data: %s\r\n", $payload->getBody()[1]);
+    }
+);
+
+// Simple Publisher.
+$client->publish(
+    'foo',
+    [
+     'Marty',
+     'McFly',
+    ]
+);
+
+// Wait for 1 message.
 $client->wait(1);
+
+// Request Response
+
+// Responding to requests.
+$sid = $client->subscribe(
+    'sayhello',
+    function ($message) {
+        $message->reply('Reply: Hello, '.$message->getBody()[1].' !!!');
+    }
+);
+
+// Request.
+$client->request(
+    'sayhello',
+    [
+     'Marty',
+     'McFly',
+    ],
+    function ($message) {
+        echo $message->getBody();
+    }
+);
 ```
 
 

VERSION

@@ -1 +1 @@
-0.8.2
+0.8.3

composer.json

@@ -8,7 +8,7 @@
         "ircmaxell/random-lib": "^1.1"
     },
     "require-dev": {
-        "phpunit/phpunit": "4.7.*",
+        "phpunit/phpunit": "5.*",
         "satooshi/php-coveralls": "dev-master",
         "squizlabs/php_codesniffer": "~2.0",
         "phpspec/phpspec": "~2.0"

examples/pubsub/jsonencodedpubsub.php

@@ -0,0 +1,28 @@
+<?php
+require_once __DIR__.'/../../vendor/autoload.php';
+
+$encoder = new \Nats\Encoders\JSONEncoder();
+$options = new \Nats\ConnectionOptions();
+$client  = new \Nats\EncodedConnection($options, $encoder);
+$client->connect();
+
+// Publish Subscribe.
+// Simple Subscriber.
+$client->subscribe(
+    'foo',
+    function ($payload) {
+        printf("Data: %s\r\n", $payload->getBody()[1]);
+    }
+);
+
+// Simple Publisher.
+$client->publish(
+    'foo',
+    [
+     'Marty',
+     'McFly',
+    ]
+);
+
+// Wait for 1 message.
+$client->wait(1);

examples/pubsub/pub.php

@@ -0,0 +1,20 @@
+<?php
+require_once __DIR__.'/../../vendor/autoload.php';
+
+$client = new \Nats\Connection();
+$client->connect();
+
+// Publish Subscribe.
+// Simple Subscriber.
+$client->subscribe(
+    'foo',
+    function ($message) {
+        printf("Data: %s\r\n", $message->getBody());
+    }
+);
+
+// Simple Publisher.
+$client->publish('foo', 'Marty McFly');
+
+// Wait for 1 message.
+$client->wait(1);

examples/pubsub/pubsub.php

@@ -0,0 +1,28 @@
+<?php
+require_once __DIR__.'/../../vendor/autoload.php';
+
+$encoder = new \Nats\Encoders\JSONEncoder();
+$options = new \Nats\ConnectionOptions();
+$client  = new \Nats\EncodedConnection($options, $encoder);
+$client->connect();
+
+// Request Response.
+// Responding to requests.
+$sid = $client->subscribe(
+    'sayhello',
+    function ($message) {
+        $message->reply('Reply: Hello, '.$message->getBody()[1].' !!!');
+    }
+);
+
+// Request.
+$client->request(
+    'sayhello',
+    [
+     'Marty',
+     'McFly',
+    ],
+    function ($message) {
+        echo $message->getBody();
+    }
+);