From 3019f8f23ffe00308fb637042d90f215157b8fc0 Mon Sep 17 00:00:00 2001
From: Mikael Nordfeldth <mmn@hethane.se>
Date: Sat, 16 Jan 2016 21:05:34 +0100
Subject: [PATCH] dbqueuemanager logic

---
 lib/dbqueuemanager.php | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/lib/dbqueuemanager.php b/lib/dbqueuemanager.php
index 62a544b1c4..4440a4d930 100644
--- a/lib/dbqueuemanager.php
+++ b/lib/dbqueuemanager.php
@@ -95,10 +95,12 @@ class DBQueueManager extends QueueManager
         } catch (NoQueueHandlerException $e) {
             $this->noHandlerFound($qi, $rep);
             return true;
+        } catch (AlreadyFulfilledException $e) {
+            $this->_log(LOG_ERR, "[{$qi->transport}:$rep] AlreadyFulfilledException thrown: {$e->getMessage()}");
+            $result = true;
         } catch (Exception $e) {
             $this->_log(LOG_ERR, "[{$qi->transport}:$rep] Exception thrown: {$e->getMessage()}");
-            $this->_fail($qi);
-            return true;
+            $result = false;
         }
 
         if ($result) {