dbqueuemanager logic

diff --git a/lib/dbqueuemanager.php b/lib/dbqueuemanager.php
index 62a544b1c4b8fbd4f5a97b0487ba55b74ab2cb05..4440a4d93060f826c0a6f8559e2bda4edc3d2f4a 100644 (file)
--- 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) {