Merge pull request #56 from desyncr/retries-delay-option

Added configuration option for `retries_delay` IronMQ option.

Author: k-k

src/DependencyInjection/Configuration.php

@@ -119,36 +119,41 @@ private function getQueuesNode()
                                 ->defaultFalse()
                                 ->info('Whether notifications are sent to the subscribers')
                             ->end()
-                             ->scalarNode('notification_retries')
-                                 ->defaultValue(3)
-                                 ->info('How many attempts the Push Notifications are retried if the Subscriber returns an error')
-                                 ->example(3)
-                             ->end()
-                             ->scalarNode('message_delay')
-                                 ->defaultValue(0)
-                                 ->info('How many seconds before messages are inititally visible in the Queue')
-                                 ->example(0)
-                             ->end()
-                             ->scalarNode('message_timeout')
-                                 ->defaultValue(30)
-                                 ->info('How many seconds the Queue hides a message while its being processed')
-                                 ->example(30)
-                             ->end()
-                             ->scalarNode('message_expiration')
-                                 ->defaultValue(604800)
-                                 ->info('How many seconds a message is kept in Queue, the default is 7 days (604800 seconds)')
-                                 ->example(604800)
-                             ->end()
-                             ->scalarNode('messages_to_receive')
-                                 ->defaultValue(1)
-                                 ->info('Max amount of messages to receive at once - an event will be fired for each individually')
-                                 ->example(1)
-                             ->end()
-                             ->scalarNode('receive_wait_time')
-                                 ->defaultValue(3)
-                                 ->info('How many seconds to Long Poll when requesting messages - if supported')
-                                 ->example(3)
-                             ->end()
+                            ->scalarNode('notification_retries')
+                                ->defaultValue(3)
+                                ->info('How many attempts the Push Notifications are retried if the Subscriber returns an error')
+                                ->example(3)
+                            ->end()
+                            ->scalarNode('notification_retry_delay')
+                                ->defaultValue(60)
+                                ->info('Delay between each Push Notification retry in seconds')
+                                ->example(3)
+                                ->end()
+                            ->scalarNode('message_delay')
+                                ->defaultValue(0)
+                                ->info('How many seconds before messages are inititally visible in the Queue')
+                                ->example(0)
+                            ->end()
+                            ->scalarNode('message_timeout')
+                                ->defaultValue(30)
+                                ->info('How many seconds the Queue hides a message while its being processed')
+                                ->example(30)
+                            ->end()
+                            ->scalarNode('message_expiration')
+                                ->defaultValue(604800)
+                                ->info('How many seconds a message is kept in Queue, the default is 7 days (604800 seconds)')
+                                ->example(604800)
+                            ->end()
+                            ->scalarNode('messages_to_receive')
+                                ->defaultValue(1)
+                                ->info('Max amount of messages to receive at once - an event will be fired for each individually')
+                                ->example(1)
+                            ->end()
+                            ->scalarNode('receive_wait_time')
+                                ->defaultValue(3)
+                                ->info('How many seconds to Long Poll when requesting messages - if supported')
+                                ->example(3)
+                            ->end()
                             ->append($this->getSubscribersNode())
                         ->end()
                     ->end()

src/Provider/IronMqProvider.php

@@ -72,6 +72,7 @@ public function create()
             $params = [
                 'push_type'     => 'multicast',
                 'retries'       => $this->options['notification_retries'],
+                'retry_delay'   => $this->options['notification_retry_delay'],
                 'subscribers'   => []
             ];
 

tests/Provider/IronMqProviderTest.php

@@ -58,15 +58,16 @@ private function getIronMqProvider(array $options = [])
     {
         $options = array_merge(
             [
-                'logging_enabled'       => false,
-                'push_notifications'    => true,
-                'notification_retries'  => 3,
-                'message_delay'         => 0,
-                'message_timeout'       => 30,
-                'message_expiration'    => 604800,
-                'messages_to_receive'   => 1,
-                'receive_wait_time'     => 3,
-                'subscribers'           => [
+                'logging_enabled'           => false,
+                'push_notifications'        => true,
+                'notification_retries'      => 3,
+                'notification_retry_delay'  => 60,
+                'message_delay'             => 0,
+                'message_timeout'           => 30,
+                'message_expiration'        => 604800,
+                'messages_to_receive'       => 1,
+                'receive_wait_time'         => 3,
+                'subscribers'               => [
                     [ 'protocol' => 'http', 'endpoint' => 'http://fake.com' ]
                 ]
             ],