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 2017/01/31 09:08:15 UTC
[2/2] camel git commit: Fixed CS. This closes #1430. This closes
#1432.
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 <da...@apache.org>
Authored: Tue Jan 31 10:05:02 2017 +0100
Committer: Claus Ibsen <da...@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;
+ });
}
}