[transport] Add redis backed transport.

Author: makasim

composer.json

@@ -8,14 +8,15 @@
     "enqueue/enqueue": "*@dev",
     "enqueue/stomp": "*@dev",
     "enqueue/amqp-ext": "*@dev",
+    "enqueue/redis": "*@dev",
     "enqueue/fs": "*@dev",
     "enqueue/enqueue-bundle": "*@dev",
     "enqueue/job-queue": "*@dev",
-    "enqueue/test": "*@dev"
-  },
-  "require-dev": {
+    "enqueue/test": "*@dev",
+
     "phpunit/phpunit": "^5",
     "doctrine/doctrine-bundle": "~1.2",
+    "predis/predis": "^1.1",
     "symfony/monolog-bundle": "^2.8|^3",
     "symfony/browser-kit": "^2.8|^3",
     "symfony/expression-language": "^2.8|^3",
@@ -46,6 +47,10 @@
       "type": "path",
       "url": "pkg/amqp-ext"
     },
+    {
+      "type": "path",
+      "url": "pkg/redis"
+    },
     {
       "type": "path",
       "url": "pkg/enqueue-bundle"

docker-compose.yml

@@ -6,6 +6,7 @@ services:
     depends_on:
       - rabbitmq
       - mysql
+      - redis
     volumes:
       - ./:/mqdev
     environment:
@@ -29,6 +30,11 @@ services:
       - RABBITMQ_DEFAULT_USER=guest
       - RABBITMQ_DEFAULT_PASS=guest
       - RABBITMQ_DEFAULT_VHOST=mqdev
+  redis:
+    image: 'redis:3'
+    ports:
+      - "6379:6379"
+
   mysql:
     image: mariadb:10
     volumes:

docker/Dockerfile

@@ -4,7 +4,7 @@ FROM ubuntu:16.04
 RUN set -x && \
     apt-get update && \
     apt-get install -y --no-install-recommends wget curl openssl ca-certificates nano netcat && \
-    apt-get install -y --no-install-recommends php php-mysql php-curl php-intl php-mbstring php-zip php-mcrypt php-xdebug php-bcmath php-xml php-amqp
+    apt-get install -y --no-install-recommends php php-mysql php-redis php-curl php-intl php-mbstring php-zip php-mcrypt php-xdebug php-bcmath php-xml php-amqp
 
 ## confis
 

phpunit.xml.dist

@@ -33,6 +33,10 @@
             <directory>pkg/fs/Tests</directory>
         </testsuite>
 
+        <testsuite name="redis-ext">
+            <directory>pkg/redis-ext/Tests</directory>
+        </testsuite>
+
         <testsuite name="enqueue-bundle">
             <directory>pkg/enqueue-bundle/Tests</directory>
         </testsuite>

pkg/amqp-ext/AmqpConnectionFactory.php

@@ -26,7 +26,8 @@ class AmqpConnectionFactory implements PsrConnectionFactory
      *     'read_timeout'  => Timeout in for income activity. Note: 0 or greater seconds. May be fractional.
      *     'write_timeout' => Timeout in for outcome activity. Note: 0 or greater seconds. May be fractional.
      *     'connect_timeout' => Connection timeout. Note: 0 or greater seconds. May be fractional.
-     *     'persisted' => bool
+     *     'persisted' => bool, Whether it use single persisted connection or open a new one for every context
+     *     'lazy' => the connection will be performed as later as possible, if the option set to true
      * ].
      *
      * @param $config

pkg/enqueue/Rpc/Promise.php

@@ -50,6 +50,7 @@ public function getMessage()
 
                     return $message;
                 }
+
                 $this->consumer->reject($message, true);
             }
         }

pkg/fs/FsConsumer.php

@@ -2,6 +2,7 @@
 
 namespace Enqueue\Fs;
 
+use Enqueue\Psr\InvalidMessageException;
 use Enqueue\Psr\PsrConsumer;
 use Enqueue\Psr\PsrMessage;
 
@@ -118,6 +119,8 @@ public function acknowledge(PsrMessage $message)
      */
     public function reject(PsrMessage $message, $requeue = false)
     {
+        InvalidMessageException::assertMessageInstanceOf($message, FsMessage::class);
+
         // do nothing on reject. fs transport always works in auto ack mode
 
         if ($requeue) {

pkg/redis/.gitignore

@@ -0,0 +1,6 @@
+*~
+/composer.lock
+/composer.phar
+/phpunit.xml
+/vendor/
+/.idea/

pkg/redis/.travis.yml

@@ -0,0 +1,21 @@
+sudo: false
+
+git:
+    depth: 1
+
+language: php
+
+php:
+    - '5.6'
+    - '7.0'
+
+cache:
+    directories:
+        - $HOME/.composer/cache
+
+install:
+    - composer self-update
+    - composer install --prefer-source
+
+script:
+    - vendor/bin/phpunit --exclude-group=functional

pkg/redis/LICENSE

@@ -0,0 +1,20 @@
+The MIT License (MIT)
+Copyright (c) 2017 Forma-Pro
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is furnished
+to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.