From: Mikael Nordfeldth <mmn@hethane.se>
Date: Sat, 16 Jan 2016 20:05:34 +0000 (+0100)
Subject: dbqueuemanager logic
X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=3019f8f23ffe00308fb637042d90f215157b8fc0;p=quix0rs-gnu-social.git

dbqueuemanager logic
---

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) {