From 26f2ad8d1b0833dc4e1826a6b6487d078648c12e Mon Sep 17 00:00:00 2001 From: gustavonalle Date: Fri, 21 Apr 2017 09:52:27 +0100 Subject: [PATCH] ISPN-7582 Fix test failure --- .../HotRodRollingUpgradesDistIT.java | 17 ++++++++++++++--- 1 file changed, 14 insertions(+), 3 deletions(-) diff --git a/server/integration/testsuite/src/test/java/org/infinispan/server/test/rollingupgrades/HotRodRollingUpgradesDistIT.java b/server/integration/testsuite/src/test/java/org/infinispan/server/test/rollingupgrades/HotRodRollingUpgradesDistIT.java index 89a8341ee06c..fec38ccec499 100644 --- a/server/integration/testsuite/src/test/java/org/infinispan/server/test/rollingupgrades/HotRodRollingUpgradesDistIT.java +++ b/server/integration/testsuite/src/test/java/org/infinispan/server/test/rollingupgrades/HotRodRollingUpgradesDistIT.java @@ -40,6 +40,11 @@ public void testHotRodRollingUpgradesDiffVersionsDist() throws Exception { // Target nodes final int managementPortServer1 = 9990; MBeanServerConnectionProvider provider1; + + // Target nodes + final int managementPortServer2 = 10090; + MBeanServerConnectionProvider provider2; + // Source node int managementPortServer3 = 10199; MBeanServerConnectionProvider provider3; @@ -101,6 +106,9 @@ public void testHotRodRollingUpgradesDiffVersionsDist() throws Exception { provider1 = new MBeanServerConnectionProvider(s1.server.getHotrodEndpoint().getInetAddress().getHostName(), managementPortServer1); + provider2 = new MBeanServerConnectionProvider(s2.server.getHotrodEndpoint().getInetAddress().getHostName(), + managementPortServer2); + provider3 = new MBeanServerConnectionProvider("127.0.0.1", managementPortServer3); final ObjectName rollMan3 = new ObjectName("jboss." + InfinispanSubsystem.SUBSYSTEM_NAME + ":type=Cache," + "name=\"default(dist_sync)\"," @@ -108,15 +116,18 @@ public void testHotRodRollingUpgradesDiffVersionsDist() throws Exception { invokeOperation(provider3, rollMan3.toString(), "recordKnownGlobalKeyset", new Object[]{}, new String[]{}); - final ObjectName rollMan1 = new ObjectName("jboss." + InfinispanSubsystem.SUBSYSTEM_NAME + ":type=Cache," + "name=\"default(dist_sync)\"," + final ObjectName rollManTarget = new ObjectName("jboss." + InfinispanSubsystem.SUBSYSTEM_NAME + ":type=Cache," + "name=\"default(dist_sync)\"," + "manager=\"clustered-new\"," + "component=RollingUpgradeManager"); - invokeOperation(provider1, rollMan1.toString(), "synchronizeData", new Object[]{"hotrod"}, + invokeOperation(provider1, rollManTarget.toString(), "synchronizeData", new Object[]{"hotrod"}, new String[]{"java.lang.String"}); - invokeOperation(provider1, rollMan1.toString(), "disconnectSource", new Object[]{"hotrod"}, + invokeOperation(provider1, rollManTarget.toString(), "disconnectSource", new Object[]{"hotrod"}, new String[]{"java.lang.String"}); + invokeOperation(provider2, rollManTarget.toString(), "disconnectSource", new Object[]{"hotrod"}, + new String[]{"java.lang.String"}); + // is source (RemoteCacheStore) really disconnected? c3.put("disconnected", "source"); c4.put("disconnectedx", "sourcex");