Actually throw NoQueueHandlerException too.

This commit is contained in:
Mikael Nordfeldth 2016-01-14 13:48:33 +01:00
parent 59e75ef966
commit c173c4faa5
1 changed files with 1 additions and 1 deletions

View File

@ -235,7 +235,7 @@ abstract class QueueManager extends IoManager
$this->_log(LOG_ERR, "Nonexistent handler class '$class' for queue '$queue'"); $this->_log(LOG_ERR, "Nonexistent handler class '$class' for queue '$queue'");
} }
} }
return null; throw new NoQueueHandlerException($queue);
} }
/** /**