Added support for the IronMQ driver.

Author: Robin van der Vleuten

DependencyInjection/BernardBernardExtension.php

@@ -33,6 +33,10 @@ public function load(array $configs, ContainerBuilder $container)
             $this->registerPhpRedisConfiguration($config['options'], $container);
         }
 
+        if ($config['driver'] == 'ironmq') {
+            $this->registerIronMQConfiguration($config['options'], $container);
+        }
+
         if ($config['serializer'] == 'jms') {
             $this->registerJmsConfiguration($container);
         }
@@ -53,6 +57,11 @@ protected function registerDoctrineConfiguration($config, $container)
         $container->setAlias('bernard.dbal_connection', 'doctrine.dbal.' . $config['connection'] . '_connection');
     }
 
+    protected function registerIronMQConfiguration($config, $container)
+    {
+        $container->getDefinition('bernard.driver.ironmq')->replaceArgument(0, new Reference($config['ironmq_service']));
+    }
+
     protected function registerJmsConfiguration($container)
     {
         $definition = new Definition('Bernard\JMSSerializer\EnvelopeHandler');

DependencyInjection/Configuration.php

@@ -19,7 +19,7 @@ public function getConfigTreeBuilder()
             ->end()
             ->children()
                 ->enumNode('driver')
-                    ->values(array('file', 'predis', 'doctrine', 'phpredis'))
+                    ->values(array('file', 'predis', 'doctrine', 'phpredis', 'ironmq'))
                 ->end()
                 ->enumNode('serializer')
                     ->defaultValue('simple')
@@ -40,6 +40,7 @@ public function getConfigTreeBuilder()
                         ->scalarNode('directory')->defaultValue('')->end()
                         ->scalarNode('connection')->defaultValue('default')->end()
                         ->scalarNode('phpredis_service')->defaultValue('snc_redis.bernard')->end()
+                        ->scalarNode('ironmq_service')->defaultNull()->end()
                         ->arrayNode('queue_map')->prototype('array')->end()
                     ->end()
                 ->end()

README.md

@@ -146,3 +146,21 @@ bernard_bernard:
 
 If you're using the [SncRedisBundle](https://github.com/snc/SncRedisBundle) you have to set logging to false for the
 bernhard client to ensure that is is a ``Redis`` instance and not wrapped.
+
+### IronMQ
+
+When using the IronMQ driver you have to configure an `IronMQ` connection instance. You can configure it like the following:
+
+``` yaml
+services:
+    ironmq_connection:
+        class: IronMQ
+        arguments:
+            - { token: %ironmq_token%, project_id: %ironmq_project_id% }
+        public: false
+
+bernard_bernard:
+    driver: ironmq
+    options:
+        ironmq_service: ironmq_connection
+```

Resources/config/services.xml

@@ -69,6 +69,10 @@
             <argument type="service" id="bernard.dbal_connection" />
         </service>
 
+        <service id="bernard.driver.ironmq" class="Bernard\Driver\IronMqDriver" public="false">
+            <argument /><!-- IronMQ connection instance -->
+        </service>
+
         <!-- Middlewares -->
         <service id="bernard.middleware.error_log" class="Bernard\Middleware\ErrorLogFactory" public="false" />
 

Tests/DependencyInjection/ConfigurationTest.php

@@ -16,7 +16,7 @@ public function testDefaults()
         $this->assertEquals('simple', $config['serializer']);
 
         $this->assertEquals(array('error_log' => false, 'logger' => false, 'failures' => false), $config['middlewares']);
-        $this->assertEquals(array('prefetch' => null, 'directory' => '', 'connection' => 'default', 'phpredis_service' => 'snc_redis.bernard', 'queue_map' => array()), $config['options']);
+        $this->assertEquals(array('prefetch' => null, 'directory' => '', 'connection' => 'default', 'phpredis_service' => 'snc_redis.bernard', 'ironmq_service' => null, 'queue_map' => array()), $config['options']);
     }
 
     public function testDriverIsRequired()