camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [2/2] camel git commit: Fixed CS. This closes #1430. This closes #1432.
Date Tue, 31 Jan 2017 09:08:15 GMT
Fixed CS. This closes #1430. This closes #1432.


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/69d57640
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/69d57640
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/69d57640

Branch: refs/heads/master
Commit: 69d57640e42c2009ea6a531b046cd6a7f6b4ed94
Parents: 6b2f245
Author: Claus Ibsen <davsclaus@apache.org>
Authored: Tue Jan 31 10:05:02 2017 +0100
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Tue Jan 31 10:05:02 2017 +0100

----------------------------------------------------------------------
 .../apache/camel/impl/cloud/ChainedServiceFilterTest.java |  2 +-
 .../org/apache/camel/impl/cloud/LoadBalancerTest.java     | 10 ++++++++--
 2 files changed, 9 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/69d57640/camel-core/src/test/java/org/apache/camel/impl/cloud/ChainedServiceFilterTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/impl/cloud/ChainedServiceFilterTest.java
b/camel-core/src/test/java/org/apache/camel/impl/cloud/ChainedServiceFilterTest.java
index dc99d11..adfb325 100644
--- a/camel-core/src/test/java/org/apache/camel/impl/cloud/ChainedServiceFilterTest.java
+++ b/camel-core/src/test/java/org/apache/camel/impl/cloud/ChainedServiceFilterTest.java
@@ -58,7 +58,7 @@ public class ChainedServiceFilterTest extends ContextTestSupport {
         ));
 
         Assert.assertEquals(2, services.size());
-        Assert.assertFalse(services.stream().anyMatch(s -> s.getHealth().isHealthy() ==
false));
+        Assert.assertFalse(services.stream().anyMatch(s -> !s.getHealth().isHealthy()));
         Assert.assertFalse(services.stream().anyMatch(s -> s.getPort() > 2000));
         Assert.assertTrue(services.stream().anyMatch(s -> s.getPort() == 1000));
         Assert.assertTrue(services.stream().anyMatch(s -> s.getPort() == 1002));

http://git-wip-us.apache.org/repos/asf/camel/blob/69d57640/camel-core/src/test/java/org/apache/camel/impl/cloud/LoadBalancerTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/impl/cloud/LoadBalancerTest.java b/camel-core/src/test/java/org/apache/camel/impl/cloud/LoadBalancerTest.java
index 56cf63f..280d8af 100644
--- a/camel-core/src/test/java/org/apache/camel/impl/cloud/LoadBalancerTest.java
+++ b/camel-core/src/test/java/org/apache/camel/impl/cloud/LoadBalancerTest.java
@@ -36,7 +36,13 @@ public class LoadBalancerTest extends ContextTestSupport {
         loadBalancer.setServiceDiscovery(serviceDiscovery);
         loadBalancer.setServiceFilter(services -> services.stream().filter(s -> s.getPort()
< 2000).collect(Collectors.toList()));
         loadBalancer.setServiceChooser(new RoundRobinServiceChooser());
-        loadBalancer.process("no-name", service -> { assertEquals(1001, service.getPort());
return false; });
-        loadBalancer.process("no-name", service -> { assertEquals(1002, service.getPort());
return false; });
+        loadBalancer.process("no-name", service -> {
+            assertEquals(1001, service.getPort());
+            return false;
+        });
+        loadBalancer.process("no-name", service -> {
+            assertEquals(1002, service.getPort());
+            return false;
+        });
     }
 }


Mime
View raw message