Set version to 1.0.8.Final

jgroups-extras · Nov 7, 2018 · 57563a6 · 57563a6
1 parent fa384e3
commit 57563a6
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 15 deletions.
diff --git a/pom.xml b/pom.xml
@@ -3,7 +3,7 @@
 
     <groupId>org.jgroups.kubernetes</groupId>
     <artifactId>jgroups-kubernetes</artifactId>
-    <version>1.0.8-SNAPSHOT</version>
+    <version>1.0.8.Final</version>
     <packaging>jar</packaging>
     <name>KUBE_PING</name>
     <url>https://github.com/jgroups-extras/jgroups-kubernetes</url>
@@ -53,7 +53,7 @@
     </scm>
 
     <properties>
-        <version.jgroups>4.0.12.Final</version.jgroups>
+        <version.jgroups>4.0.15.Final</version.jgroups>
         <version.junit>4.12</version.junit>
         <version.assertj>3.8.0</version.assertj>
         <maven.compiler.source>1.8</maven.compiler.source>

diff --git a/src/test/java/org/jgroups/ping/kube/test/RollingUpdateTest.java b/src/test/java/org/jgroups/ping/kube/test/RollingUpdateTest.java
@@ -1,13 +1,5 @@
 package org.jgroups.ping.kube.test;
 
-import static org.jgroups.ping.kube.test.util.FreePortFinder.findFreePort;
-
-import java.net.InetAddress;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Set;
-import java.util.stream.Collectors;
-
 import org.assertj.core.api.Assertions;
 import org.jgroups.JChannel;
 import org.jgroups.Message;
@@ -19,6 +11,14 @@
 import org.jgroups.stack.IpAddress;
 import org.junit.Test;
 
+import java.net.InetAddress;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+import static org.jgroups.ping.kube.test.util.FreePortFinder.findFreePort;
+
 /**
  * Tests Rolling update scenarios.
  *
@@ -40,7 +40,7 @@ public void testPuttingAllNodesInTheSameClusterDuringRollingUpdate() throws Exce
             .map(e -> ((IpAddress)e.getDest()).getIpAddress().getHostAddress())
             .collect(Collectors.toSet());
       List<String> allPodsFromKubernetesApi = testedProtocol.getPods().stream()
-            .map(pod -> pod.getIp())
+            .map(Pod::getIp)
             .collect(Collectors.toList());
 
       //then
@@ -57,21 +57,21 @@ public void testPutOnlyNodesWithTheSameParentDuringRollingUpdate() throws Except
       sendInitialDiscovery(testedProtocol);
       String senderParentDeployment = testedProtocol.getPods().stream()
             .filter(pod -> "127.0.0.1".equals(pod.getIp()))
-            .map(pod -> pod.getParentDeployment())
+            .map(Pod::getParentDeployment)
             .findFirst().get();
       Set<String> membersUsedForDiscovery = testedProtocol.getCollectedMessages().stream()
             .map(e -> ((IpAddress)e.getDest()).getIpAddress().getHostAddress())
             .collect(Collectors.toSet());
       List<String> allowedPodsFromKubernetesApi = testedProtocol.getPods().stream()
             .filter(pod -> senderParentDeployment.equals(pod.getParentDeployment()))
-            .map(pod -> pod.getIp())
+            .map(Pod::getIp)
             .collect(Collectors.toList());
 
       //then
       Assertions.assertThat(allowedPodsFromKubernetesApi).containsAll(membersUsedForDiscovery);
    }
 
-   private void sendInitialDiscovery(KUBE_PING kubePingProtocol) throws Exception {
+   private static void sendInitialDiscovery(KUBE_PING kubePingProtocol) throws Exception {
       new JChannel(
             new TCP().setValue("bind_addr", InetAddress.getLoopbackAddress()).setValue("bind_port", findFreePort()),
             kubePingProtocol,
@@ -83,7 +83,7 @@ private void sendInitialDiscovery(KUBE_PING kubePingProtocol) throws Exception {
    static class KUBE_PING_FOR_TESTING extends KUBE_PING {
 
       private final String resourceFile;
-      private List<Message> collectedMessages = new ArrayList<>();
+      private final List<Message> collectedMessages = new ArrayList<>();
       private List<Pod> pods;
 
       public KUBE_PING_FOR_TESTING(String resourceFile) {