Repository: camel Updated Branches: refs/heads/master 1fa59fbc2 -> cebc58cd7
Do not use deprecated api Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/cebc58cd Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/cebc58cd Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/cebc58cd Branch: refs/heads/master Commit: cebc58cd7f35b34d6a7cd176ebfe2aebb27f513e Parents: 1fa59fb Author: Claus Ibsen <davscl...@apache.org> Authored: Thu Apr 7 16:23:11 2016 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Thu Apr 7 16:25:31 2016 +0200 ---------------------------------------------------------------------- .../main/java/org/apache/camel/rx/support/ObserverSender.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/cebc58cd/components/camel-rx/src/main/java/org/apache/camel/rx/support/ObserverSender.java ---------------------------------------------------------------------- diff --git a/components/camel-rx/src/main/java/org/apache/camel/rx/support/ObserverSender.java b/components/camel-rx/src/main/java/org/apache/camel/rx/support/ObserverSender.java index 0cf5d90..d134aaa 100644 --- a/components/camel-rx/src/main/java/org/apache/camel/rx/support/ObserverSender.java +++ b/components/camel-rx/src/main/java/org/apache/camel/rx/support/ObserverSender.java @@ -53,14 +53,14 @@ public class ObserverSender<T> implements Observer<T> { @Override public void onError(Throwable e) { - Exchange exchange = producer.createExchange(); + Exchange exchange = producer.getEndpoint().createExchange(); exchange.setException(e); send(exchange); } @Override public void onNext(T o) { - Exchange exchange = producer.createExchange(); + Exchange exchange = producer.getEndpoint().createExchange(); exchange.getIn().setBody(o); send(exchange); }
