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 <davscl...@apache.org> Authored: Tue Jan 31 10:05:02 2017 +0100 Committer: Claus Ibsen <davscl...@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; + }); } }
