sendPushMessageToAll -> sendMovingPushToAll

Author: ggivo

src/test/java/redis/clients/jedis/upgrade/UnifiedJedisProactiveRebindTest.java

@@ -88,7 +88,7 @@ public void testProactiveRebind() throws Exception {
       assertEquals(0, mockServer2.getConnectedClientCount());
 
       // 2. Send MOVING notification on server1 -> MOVING 30 localhost:port2
-      mockServer1.sendPushMessageToAll("MOVING", "30", server2Address.toString());
+      mockServer1.sendMovingPushToAll( 30L, server2Address.toString());
 
       // 3. Perform PING command
       // This should trigger read of the MOVING notification and rebind to server2
@@ -132,7 +132,7 @@ public void testActiveConnectionShouldBeDisposedOnRebind() {
       assertEquals(0, mockServer2.getConnectedClientCount());
 
       // 2. Send MOVING notification on server1 -> MOVING 30 localhost:port2
-      mockServer1.sendPushMessageToAll("MOVING", "30", server2Address.toString());
+      mockServer1.sendMovingPushToAll( 30L, server2Address.toString());
 
       // 3. Active connection should be still usable until closed and returned to the pools
       assertTrue(activeConnection.ping());
@@ -176,7 +176,7 @@ public void testIdleConnectionShouldBeDisposedOnRebind() {
 
       // 2. Send MOVING notification on server1 -> MOVING 30 localhost:port2
       String server2Address = "localhost:" + mockServer2.getPort();
-      mockServer1.sendPushMessageToAll("MOVING", "30", server2Address);
+      mockServer1.sendMovingPushToAll( 30L, server2Address);
 
       // 3. perform a command on active connection to trigger rebind
       assertTrue(activeConnection.ping());
@@ -213,7 +213,7 @@ public void testNewPoolConnectionsCreatedAgainstMovingTarget() {
       assertEquals(0, mockServer2.getConnectedClientCount());
 
       // 2. Send MOVING notification on server1 -> MOVING 30 localhost:port2
-      mockServer1.sendPushMessageToAll("MOVING", "30", server2Address.toString());
+      mockServer1.sendMovingPushToAll( 30L, server2Address.toString());
 
       // 3. perform a command on active connection to trigger rebind
       assertTrue(activeConnection.ping());
@@ -250,7 +250,7 @@ public void testPoolConnectionsWithProactiveRebindDisabled() {
       assertEquals(0, mockServer2.getConnectedClientCount());
 
       // 2. Send MOVING notification on server1 -> MOVING 30 localhost:port2
-      mockServer1.sendPushMessageToAll("MOVING", "30", server2Address.toString());
+      mockServer1.sendMovingPushToAll( 30L, server2Address.toString());
 
       // 3. Perform PING command
       // This should trigger read of the MOVING notification processing