This is an automated email from the ASF dual-hosted git repository. bvahdat pushed a commit to branch maven-checkstyle-upgrade-and-violation-fixes in repository https://gitbox.apache.org/repos/asf/camel.git
commit 08f187909c51f8a56adf849008eedb49bdc5a9d1 Author: Otavio Rodolfo Piske <orpi...@users.noreply.github.com> AuthorDate: Mon Jun 21 15:22:34 2021 +0200 (chores) Formatting fixes for camel-jta and camel-kubernetes (#5722) --- .../component/kubernetes/cluster/KubernetesClusterServiceTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterServiceTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterServiceTest.java index d951ccc..d862fce 100644 --- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterServiceTest.java +++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterServiceTest.java @@ -378,7 +378,7 @@ public class KubernetesClusterServiceTest extends CamelTestSupport { } else { if (Objects.equals(info.getLeader(), currentLeaderLastSeen.getLeader())) { currentLeaderLastSeen = info; - } else if (info.getLeader() != null && !info.getLeader().equals(currentLeaderLastSeen.getLeader())) { + } else if (isCurrentLeader(info.getLeader(), currentLeaderLastSeen.getLeader())) { // switch long delay = info.getChangeTimestamp() - currentLeaderLastSeen.getChangeTimestamp(); assertTrue(delay >= TimeUnit.MILLISECONDS.convert(minimum, unit),