- $qi = Queue_item::pkeyGet(array('notice_id' => $notice->id,
- 'transport' => $queue));
+ $rep = $this->logrep($item);
+ $this->_log(LOG_DEBUG, 'Got '._ve($rep).' for transport '._ve($qi->transport));
+
+ try {
+ $handler = $this->getHandler($qi->transport);
+ $result = $handler->handle($item);
+ } catch (NoQueueHandlerException $e) {
+ $this->noHandlerFound($qi, $rep);
+ 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) {
+ $this->_log(LOG_ERR, "[{$qi->transport}:$rep] ".get_class($e).' thrown ('._ve($e->getMessage()).'), ignoring queue_item '._ve($qi->getID()));
+ $result = true;
+ } catch (Exception $e) {
+ $this->_log(LOG_ERR, "[{$qi->transport}:$rep] Exception (".get_class($e).') thrown: '._ve($e->getMessage()));
+ $result = false;
+ }