+ try {
+ $item = $this->decode($qi->frame);
+ } catch (Exception $e) {
+ $this->_log(LOG_INFO, "[{$qi->transport}] Discarding: ".$e->getMessage());
+ $this->_done($qi);
+ return true;
+ }
+
+ $rep = $this->logrep($item);
+ $this->_log(LOG_DEBUG, "Got {$rep} for transport {$qi->transport}");
+
+ try {
+ $handler = $this->getHandler($qi->transport);
+ $result = $handler->handle($item);
+ } 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()}");
+ $result = false;
+ }