Handle exceptions in QueueHandler classes

diff --git a/lib/dbqueuemanager.php b/lib/dbqueuemanager.php
index 9fb77eed9645c380beb0901042e21a7854048321..3adac08971f8095d21424a605b29099e1da08158 100644 (file)
--- a/lib/dbqueuemanager.php
+++ b/lib/dbqueuemanager.php
@@ -91,7 +91,13 @@ class DBQueueManager extends QueueManager
         
         $handler = $this->getHandler($qi->transport);
         if ($handler) {
-            if ($handler->handle($item)) {
+            try {
+                $result = $handler->handle($item)
+            } catch (Exception $e) {
+                $result = false;
+                $this->_log(LOG_ERR, "[{$qi->transport}:$rep] Exception thrown: {$e->getMessage()}");
+            }
+            if ($result) {
                 $this->_log(LOG_INFO, "[{$qi->transport}:$rep] Successfully handled item");
                 $this->_done($qi);
             } else {