You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2016/04/07 16:25:39 UTC
camel git commit: Do not use deprecated api
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 <da...@apache.org>
Authored: Thu Apr 7 16:23:11 2016 +0200
Committer: Claus Ibsen <da...@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);
}