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 2015/05/06 10:24:42 UTC
camel git commit: Fixed CS
Repository: camel
Updated Branches:
refs/heads/master 0f38457bc -> e816247d6
Fixed CS
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/e816247d
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/e816247d
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/e816247d
Branch: refs/heads/master
Commit: e816247d6e788cd92b0bfef48837fb1c3d79a68b
Parents: 0f38457
Author: Claus Ibsen <da...@apache.org>
Authored: Wed May 6 10:27:52 2015 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Wed May 6 10:27:52 2015 +0200
----------------------------------------------------------------------
.../camel-rx/src/main/java/org/apache/camel/rx/ReactiveCamel.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/e816247d/components/camel-rx/src/main/java/org/apache/camel/rx/ReactiveCamel.java
----------------------------------------------------------------------
diff --git a/components/camel-rx/src/main/java/org/apache/camel/rx/ReactiveCamel.java b/components/camel-rx/src/main/java/org/apache/camel/rx/ReactiveCamel.java
index e0eb869..d1365bb 100644
--- a/components/camel-rx/src/main/java/org/apache/camel/rx/ReactiveCamel.java
+++ b/components/camel-rx/src/main/java/org/apache/camel/rx/ReactiveCamel.java
@@ -141,7 +141,7 @@ public class ReactiveCamel {
* Return a newly created {@link Observable} without conversion
*/
protected Observable<Exchange> createEndpointObservable(final Endpoint endpoint) {
- return new EndpointObservable<Exchange>(endpoint, new EndpointSubscribeFunc<>(endpoint, new Func1<Exchange, Exchange>() {
+ return new EndpointObservable<Exchange>(endpoint, new EndpointSubscribeFunc<Exchange>(endpoint, new Func1<Exchange, Exchange>() {
@Override
public Exchange call(Exchange exchange) {
return exchange;