dbqueuemanager should ignore on no-result-exceptions

This commit is contained in:
Mikael Nordfeldth 2016-08-16 20:27:41 +02:00
parent 557e430c7d
commit fc06c599bc
1 changed files with 5 additions and 2 deletions

View File

@ -95,11 +95,14 @@ class DBQueueManager extends QueueManager
} catch (NoQueueHandlerException $e) { } catch (NoQueueHandlerException $e) {
$this->noHandlerFound($qi, $rep); $this->noHandlerFound($qi, $rep);
return true; return true;
} catch (NoResultException $e) {
$this->_log(LOG_ERR, "[{$qi->transport}:$rep] ".get_class($e).' thrown ('._ve($e->getMessage()).'), ignoring queue_item '._ve($qi->getID()));
$result = true;
} catch (AlreadyFulfilledException $e) { } catch (AlreadyFulfilledException $e) {
$this->_log(LOG_ERR, "[{$qi->transport}:$rep] AlreadyFulfilledException thrown: {$e->getMessage()}"); $this->_log(LOG_ERR, "[{$qi->transport}:$rep] ".get_class($e).' thrown ('._ve($e->getMessage()).'), ignoring queue_item '._ve($qi->getID()));
$result = true; $result = true;
} catch (Exception $e) { } catch (Exception $e) {
$this->_log(LOG_ERR, "[{$qi->transport}:$rep] Exception thrown: {$e->getMessage()}"); $this->_log(LOG_ERR, "[{$qi->transport}:$rep] Exception (".get_class($e).') thrown: '._ve($e->getMessage()));
$result = false; $result = false;
} }