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),

Reply via email to