Throw exception of no consumer (#21)

* Throw exception of no consumer * Added changelog
Happyr · Nov 2, 2016 · c4b75e8 · c4b75e8
1 parent 2cdfbe2
commit c4b75e8
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 8 deletions.
diff --git a/Changelog.md b/Changelog.md
@@ -2,6 +2,12 @@
 
 The change log describes what is "Added", "Removed", "Changed" or "Fixed" between each release. 
 
+## 0.2.3
+
+### Added
+
+- If no consumer is found we throw an exception to make sure we requeue the message. 
+
 ## 0.2.2
 
 ### Added 

diff --git a/Service/ConsumerWrapper.php b/Service/ConsumerWrapper.php
@@ -107,15 +107,10 @@ private function log($level, $message, array $context = [])
     private function doConsume($queueName, $message, SerializedEnvelopeConsumer $consumer = null)
     {
         if ($consumer === null) {
-            $this->log(
-                'error',
-                sprintf('No consumer was found for queue named "%s"', $queueName),
-                [
-                    'message' => $message,
-                ]
-            );
+            $exceptionMessage = sprintf('No consumer was found for queue named "%s"', $queueName);
+            $this->log('alert', $exceptionMessage, ['message' => $message]);
 
-            return;
+            throw new \RuntimeException($exceptionMessage);
         }
 
         try {