Fixing error in consume catchException

Also added throwables support Signed-off-by: RJ Garcia <rj@bighead.net>
krakphp · Jun 3, 2017 · a2370a8 · a2370a8
1 parent c7c6711
commit a2370a8
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 1 deletion.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -2,6 +2,14 @@
 
 ## Unreleased
 
+### Added
+
+- Support for php7 throwables in catching exceptions
+
+### Fixed
+
+- Bug in consume where exceptions weren't being caught
+
 ## 0.3.3 - 2017-06-02
 
 ### Added

diff --git a/src/Pipeline/consume.php b/src/Pipeline/consume.php
@@ -38,7 +38,9 @@ function catchExceptionConsume() {
         try {
             return $next($job);
         } catch (\Exception $e) {
-            return Result::failed(['exception' => $e->getMessage()]);
+            return Job\failed(['exception' => $e->getMessage()]);
+        } catch (\Throwable $e) {
+            return Job\failed(['exception' => $e->getMessage()]);
         }
     };
 }