diff --git a/src/lib/Combiner.php b/src/lib/Combiner.php index 949001d..58ecaf9 100644 --- a/src/lib/Combiner.php +++ b/src/lib/Combiner.php @@ -83,10 +83,7 @@ private function submitBatch() { call_user_func($this->checkpointer,$result); } if(!$result['success']) { - /** - * @todo we need to kill this process osmehow - */ - exit(); + throw new \Exception("Could not put message on bus - result is: " . $result); } } } @@ -170,4 +167,4 @@ public function end() { $this->reset(); $this->uploader->end(); } -} \ No newline at end of file +}