- $notice = $object;
-
- $handler = $this->getHandler($queue);
- if ($handler) {
- $handler->handle_notice($notice);
- } else {
- if (Event::handle('UnqueueHandleNotice', array(&$notice, $queue))) {
- throw new ServerException("UnQueueManager: Unknown queue: $queue");
+ try {
+ $handler = $this->getHandler($transport);
+ $handler->handle($object);
+ } catch (NoQueueHandlerException $e) {
+ if (Event::handle('UnqueueHandleNotice', array(&$object, $transport))) {
+ throw new ServerException("UnQueueManager: Unknown queue transport: $transport");