CAMEL-8515: Camel marshal/unmarshal - Should catch throwable in case dataformat causes an java.lang.Error
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/89cb7e6c Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/89cb7e6c Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/89cb7e6c Branch: refs/heads/camel-2.15.x Commit: 89cb7e6cca3473d6f40779458741704c85d63ebf Parents: 5d7b3b1 Author: Claus Ibsen <davscl...@apache.org> Authored: Thu Mar 19 15:46:38 2015 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Thu Mar 19 15:47:38 2015 +0100 ---------------------------------------------------------------------- .../src/main/java/org/apache/camel/processor/MarshalProcessor.java | 2 +- .../main/java/org/apache/camel/processor/UnmarshalProcessor.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/89cb7e6c/camel-core/src/main/java/org/apache/camel/processor/MarshalProcessor.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/processor/MarshalProcessor.java b/camel-core/src/main/java/org/apache/camel/processor/MarshalProcessor.java index efa2b8e..7a45624 100644 --- a/camel-core/src/main/java/org/apache/camel/processor/MarshalProcessor.java +++ b/camel-core/src/main/java/org/apache/camel/processor/MarshalProcessor.java @@ -82,7 +82,7 @@ public class MarshalProcessor extends ServiceSupport implements AsyncProcessor, byte[] data = os.toByteArray(); out.setBody(data); } - } catch (Exception e) { + } catch (Throwable e) { // remove OUT message, as an exception occurred exchange.setOut(null); exchange.setException(e); http://git-wip-us.apache.org/repos/asf/camel/blob/89cb7e6c/camel-core/src/main/java/org/apache/camel/processor/UnmarshalProcessor.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/processor/UnmarshalProcessor.java b/camel-core/src/main/java/org/apache/camel/processor/UnmarshalProcessor.java index 934fd2a..e81a283 100644 --- a/camel-core/src/main/java/org/apache/camel/processor/UnmarshalProcessor.java +++ b/camel-core/src/main/java/org/apache/camel/processor/UnmarshalProcessor.java @@ -76,7 +76,7 @@ public class UnmarshalProcessor extends ServiceSupport implements AsyncProcessor } else { out.setBody(result); } - } catch (Exception e) { + } catch (Throwable e) { // remove OUT message, as an exception occurred exchange.setOut(null); exchange.setException(e);
