change option name

Author: Henning

pkg/dbal/DbalContext.php

@@ -39,26 +39,21 @@ class DbalContext implements Context
      * Callable must return instance of Doctrine\DBAL\Connection once called.
      *
      * @param Connection|callable $connection
-     * @param array               $config
      */
     public function __construct($connection, array $config = [])
     {
         $this->config = array_replace([
             'table_name' => 'enqueue',
             'polling_interval' => null,
-            'subscription_interval' => null,
+            'subscription_polling_interval' => null,
         ], $config);
 
         if ($connection instanceof Connection) {
             $this->connection = $connection;
         } elseif (is_callable($connection)) {
             $this->connectionFactory = $connection;
         } else {
-            throw new \InvalidArgumentException(sprintf(
-                'The connection argument must be either %s or callable that returns %s.',
-                Connection::class,
-                Connection::class
-            ));
+            throw new \InvalidArgumentException(sprintf('The connection argument must be either %s or callable that returns %s.', Connection::class, Connection::class));
         }
     }
 
@@ -136,8 +131,8 @@ public function createSubscriptionConsumer(): SubscriptionConsumer
             $consumer->setRedeliveryDelay($this->config['redelivery_delay']);
         }
 
-        if (isset($this->config['subscription_interval'])) {
-            $consumer->setSubscriptionInterval($this->config['subscription_interval']);
+        if (isset($this->config['subscription_polling_interval'])) {
+            $consumer->setPollingInterval($this->config['subscription_polling_interval']);
         }
 
         return $consumer;
@@ -207,10 +202,7 @@ public function getDbalConnection(): Connection
         if (false == $this->connection) {
             $connection = call_user_func($this->connectionFactory);
             if (false == $connection instanceof Connection) {
-                throw new \LogicException(sprintf(
-                    'The factory must return instance of Doctrine\DBAL\Connection. It returns %s',
-                    is_object($connection) ? get_class($connection) : gettype($connection)
-                ));
+                throw new \LogicException(sprintf('The factory must return instance of Doctrine\DBAL\Connection. It returns %s', is_object($connection) ? get_class($connection) : gettype($connection)));
             }
 
             $this->connection = $connection;

pkg/dbal/DbalSubscriptionConsumer.php

@@ -41,11 +41,8 @@ class DbalSubscriptionConsumer implements SubscriptionConsumer
      *
      * @var int
      */
-    private $subscriptionInterval = 200;
+    private $pollingInterval = 200;
 
-    /**
-     * @param DbalContext $context
-     */
     public function __construct(DbalContext $context)
     {
         $this->context = $context;
@@ -70,9 +67,14 @@ public function setRedeliveryDelay(int $redeliveryDelay): self
         return $this;
     }
 
-    public function setSubscriptionInterval(int $subscriptionInterval): self
+    public function getPollingInterval(): int
+    {
+        return $this->pollingInterval;
+    }
+
+    public function setPollingInterval(int $msec): self
     {
-        $this->subscriptionInterval = $subscriptionInterval;
+        $this->pollingInterval = $msec;
 
         return $this;
     }
@@ -116,7 +118,7 @@ public function consume(int $timeout = 0): void
             } else {
                 $currentQueueNames = [];
 
-                usleep($this->subscriptionInterval * 1000); // 200ms
+                usleep($this->getPollingInterval() * 1000);
             }
 
             if ($timeout && microtime(true) >= $now + $timeout) {

pkg/dbal/Tests/DbalContextTest.php

@@ -39,6 +39,7 @@ public function testCouldBeConstructedWithEmptyConfiguration()
         $this->assertAttributeEquals([
             'table_name' => 'enqueue',
             'polling_interval' => null,
+            'subscription_polling_interval' => null,
         ], 'config', $factory);
     }
 
@@ -47,11 +48,13 @@ public function testCouldBeConstructedWithCustomConfiguration()
         $factory = new DbalContext($this->createConnectionMock(), [
             'table_name' => 'theTableName',
             'polling_interval' => 12345,
+            'subscription_polling_interval' => 12345,
         ]);
 
         $this->assertAttributeEquals([
             'table_name' => 'theTableName',
             'polling_interval' => 12345,
+            'subscription_polling_interval' => 12345,
         ], 'config', $factory);
     }