add TLS support

.travis.yml

@@ -25,7 +25,8 @@ before_script:
       sudo service rabbitmq-server start;
     fi
   - if [ "$STOMP_PROVIDER" = 'activemq' ]; then
-      sudo apt install activemq tree;
+      sudo apt update;
+      sudo apt install activemq;
       sudo cp tests/utils/activemq.xml /etc/activemq/instances-available/main/;
       sudo ln -s /etc/activemq/instances-available/main /etc/activemq/instances-enabled/main;
       sudo service activemq start;

README.md

@@ -57,6 +57,7 @@ $loop->run();
 * `vhost`: Virtual host, defaults to `/`.
 * `login`: Login user name, defaults to `guest`.
 * `passcode`: Login passcode, defaults to `guest`.
+* `protocol`: Protocol to connect with, defaults to `tcp` (use `tls` for TLS-enabled connections).
 
 ## Acknowledgement
 
@@ -95,6 +96,10 @@ To run the test suite, you need PHPUnit.
 
     $ phpunit
 
+Or, to run the functional tests against a local message queue:
+
+    $ STOMP_PROVIDER=rabbitmq phpunit -c phpunit-functional.xml.dist
+
 ## License
 
 MIT, see LICENSE.

examples/config/activemq-tls.php

@@ -0,0 +1,10 @@
+<?php
+
+return array(
+    'host'     => '127.0.0.1',
+    'port'     => '61614',
+    'login'    => 'system',
+    'passcode' => 'manager',
+    'vhost'    => '/',
+    'protocol' => 'tls',
+);

src/Factory.php

@@ -17,6 +17,7 @@ class Factory
         'vhost'     => '/',
         'login'     => 'guest',
         'passcode'  => 'guest',
+        'protocol'  => 'tcp',
     );
 
     private $loop;
@@ -51,7 +52,7 @@ public function createClient(array $options = array())
 
     public function createConnection($options)
     {
-        $address = 'tcp://'.$options['host'].':'.$options['port'];
+        $address = $options['protocol'].'://'.$options['host'].':'.$options['port'];
 
         if (false === $fd = @stream_socket_client($address, $errno, $errstr)) {
             $message = "Could not bind to $address: $errstr";

tests/React/Tests/Stomp/FactoryTest.php

@@ -13,7 +13,7 @@ public function testCreateConnection()
 
         $loop = $this->createMock('React\EventLoop\LoopInterface');
         $factory = new Factory($loop);
-        $conn = $factory->createConnection(array('host' => 'localhost', 'port' => 37234));
+        $conn = $factory->createConnection(array('host' => 'localhost', 'port' => 37234, 'protocol' => 'tcp'));
 
         $this->assertInstanceOf('React\Socket\Connection', $conn);
     }
@@ -25,7 +25,7 @@ public function itShouldThrowAnExceptionInCaseSocketCreationFails()
         $factory = new Factory($loop);
 
         try {
-            $factory->createConnection(array('host' => 'localhost', 'port' => 37235));
+            $factory->createConnection(array('host' => 'localhost', 'port' => 37235, 'protocol' => 'tcp'));
             $this->fail('This should have raised an exception');
         } catch (ConnectionException $e) {