camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject camel git commit: Fixed CS
Date Wed, 06 May 2015 08:24:42 GMT
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 <davsclaus@apache.org>
Authored: Wed May 6 10:27:52 2015 +0200
Committer: Claus Ibsen <davsclaus@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;


Mime
View raw message