fix

Author: makasim

Diff for: pkg/dbal/DbalConnectionFactory.php

@@ -45,7 +45,12 @@ public function __construct($config = 'mysql:')
             throw new \LogicException('The config must be either an array of options, a DSN string or null');
         }
 
-        $this->config = $config;
+        $this->config = array_replace_recursive([
+            'connection' => [],
+            'table_name' => 'enqueue',
+            'polling_interval' => 1000,
+            'lazy' => true,
+        ], $config);
     }
 
     /**

Diff for: pkg/dbal/DbalContext.php

@@ -193,4 +193,16 @@ public function createDataBaseTable()
 
         $sm->createTable($table);
     }
+
+    /**
+     * @param DbalDestination $queue
+     */
+    public function purgeQueue(DbalDestination $queue)
+    {
+        $this->getDbalConnection()->delete(
+            $this->getTableName(),
+            ['queue' => $queue->getQueueName()],
+            ['queue' => Type::STRING]
+        );
+    }
 }