RabbitMQ tests

Author: mnapoli

composer.json

@@ -7,6 +7,7 @@
     "autoload": {
         "psr-0": {
             "MyCLabs": "src/",
+            "FunctionalTest": "tests/",
             "UnitTest": "tests/"
         }
     },

phpunit.xml.dist

@@ -11,6 +11,9 @@
          bootstrap="./tests/bootstrap.php">
 
     <testsuites>
+        <testsuite name="Work functional tests">
+            <directory>./tests/FunctionalTest/</directory>
+        </testsuite>
         <testsuite name="Work unit tests">
             <directory>./tests/UnitTest/</directory>
         </testsuite>

tests/FunctionalTest/MyCLabs/Work/RabbitMQ/RabbitMQTest.php

@@ -0,0 +1,36 @@
+<?php
+
+namespace UnitTest\MyCLabs\Work\Dispatcher;
+
+use MyCLabs\Work\Dispatcher\RabbitMQWorkDispatcher;
+use PhpAmqpLib\Connection\AMQPConnection;
+use PhpAmqpLib\Exception\AMQPRuntimeException;
+use PHPUnit_Framework_TestCase;
+
+/**
+ * Test executing tasks through RabbitMQ
+ */
+class RabbitMQTest extends PHPUnit_Framework_TestCase
+{
+    const QUEUE_NAME = 'myclabs_work_test';
+
+    public function testRunBackground()
+    {
+        try {
+            $connection = new AMQPConnection('localhost', 5672, 'guest', 'guest');
+        } catch (AMQPRuntimeException $e) {
+            // RabbitMQ not installed, mark test skipped
+            $this->markTestSkipped('RabbitMQ is not installed or was not found');
+            return;
+        }
+
+        $channel = $connection->channel();
+
+        $channel->queue_declare(self::QUEUE_NAME, false, false, false, false);
+
+        $workDispatcher = new RabbitMQWorkDispatcher($channel, self::QUEUE_NAME);
+
+        $channel->close();
+        $connection->close();
+    }
+}