Skip to content

Commit c62764b

Browse files
YehEmilykirklund
YehEmily
authored and
kirklund
committed
GEODE-3271: Renaming punePort variables, refactoring WANCommandsTestBase
This closes apache#647
1 parent e1befef commit c62764b

14 files changed

+396
-426
lines changed

‎geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/CreateAndDestroyGatewaySenderCommandsDUnitTest.java

+48-48
Original file line numberDiff line numberDiff line change
@@ -44,13 +44,13 @@ public class CreateAndDestroyGatewaySenderCommandsDUnitTest extends WANCommandTe
4444
*/
4545
@Test
4646
public void testCreateDestroyGatewaySenderWithDefault() {
47-
Integer punePort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
48-
propsSetUp(punePort);
47+
Integer dsIdPort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
48+
propsSetUp(dsIdPort);
4949

50-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
51-
vm3.invoke(() -> createCache(punePort));
52-
vm4.invoke(() -> createCache(punePort));
53-
vm5.invoke(() -> createCache(punePort));
50+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
51+
vm3.invoke(() -> createCache(dsIdPort));
52+
vm4.invoke(() -> createCache(dsIdPort));
53+
vm5.invoke(() -> createCache(dsIdPort));
5454

5555
String command = CliStrings.CREATE_GATEWAYSENDER + " --" + CliStrings.CREATE_GATEWAYSENDER__ID
5656
+ "=ln" + " --" + CliStrings.CREATE_GATEWAYSENDER__REMOTEDISTRIBUTEDSYSTEMID + "=2";
@@ -82,13 +82,13 @@ public void testCreateDestroyGatewaySenderWithDefault() {
8282
*/
8383
@Test
8484
public void testCreateDestroyGatewaySender() {
85-
Integer punePort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
86-
propsSetUp(punePort);
85+
Integer dsIdPort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
86+
propsSetUp(dsIdPort);
8787

88-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
89-
vm3.invoke(() -> createCache(punePort));
90-
vm4.invoke(() -> createCache(punePort));
91-
vm5.invoke(() -> createCache(punePort));
88+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
89+
vm3.invoke(() -> createCache(dsIdPort));
90+
vm4.invoke(() -> createCache(dsIdPort));
91+
vm5.invoke(() -> createCache(dsIdPort));
9292

9393
int socketReadTimeout = GatewaySender.MINIMUM_SOCKET_READ_TIMEOUT + 1000;
9494
String command = CliStrings.CREATE_GATEWAYSENDER + " --" + CliStrings.CREATE_GATEWAYSENDER__ID
@@ -139,13 +139,13 @@ public void testCreateDestroyGatewaySender() {
139139
*/
140140
@Test
141141
public void testCreateDestroyGatewaySenderWithGatewayEventFilters() {
142-
Integer punePort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
143-
propsSetUp(punePort);
142+
Integer dsIdPort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
143+
propsSetUp(dsIdPort);
144144

145-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
146-
vm3.invoke(() -> createCache(punePort));
147-
vm4.invoke(() -> createCache(punePort));
148-
vm5.invoke(() -> createCache(punePort));
145+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
146+
vm3.invoke(() -> createCache(dsIdPort));
147+
vm4.invoke(() -> createCache(dsIdPort));
148+
vm5.invoke(() -> createCache(dsIdPort));
149149

150150
int socketReadTimeout = GatewaySender.MINIMUM_SOCKET_READ_TIMEOUT + 1000;
151151
String command = CliStrings.CREATE_GATEWAYSENDER + " --" + CliStrings.CREATE_GATEWAYSENDER__ID
@@ -203,13 +203,13 @@ public void testCreateDestroyGatewaySenderWithGatewayEventFilters() {
203203
*/
204204
@Test
205205
public void testCreateDestroyGatewaySenderWithGatewayTransportFilters() {
206-
Integer punePort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
207-
propsSetUp(punePort);
206+
Integer dsIdPort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
207+
propsSetUp(dsIdPort);
208208

209-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
210-
vm3.invoke(() -> createCache(punePort));
211-
vm4.invoke(() -> createCache(punePort));
212-
vm5.invoke(() -> createCache(punePort));
209+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
210+
vm3.invoke(() -> createCache(dsIdPort));
211+
vm4.invoke(() -> createCache(dsIdPort));
212+
vm5.invoke(() -> createCache(dsIdPort));
213213

214214
int socketReadTimeout = GatewaySender.MINIMUM_SOCKET_READ_TIMEOUT + 1000;
215215
String command = CliStrings.CREATE_GATEWAYSENDER + " --" + CliStrings.CREATE_GATEWAYSENDER__ID
@@ -267,13 +267,13 @@ public void testCreateDestroyGatewaySenderWithGatewayTransportFilters() {
267267
*/
268268
@Test
269269
public void testCreateDestroyGatewaySender_OnMember() {
270-
Integer punePort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
271-
propsSetUp(punePort);
270+
Integer dsIdPort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
271+
propsSetUp(dsIdPort);
272272

273-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
274-
vm3.invoke(() -> createCache(punePort));
275-
vm4.invoke(() -> createCache(punePort));
276-
vm5.invoke(() -> createCache(punePort));
273+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
274+
vm3.invoke(() -> createCache(dsIdPort));
275+
vm4.invoke(() -> createCache(dsIdPort));
276+
vm5.invoke(() -> createCache(dsIdPort));
277277

278278
final DistributedMember vm3Member = vm3.invoke(this::getMember);
279279
int socketReadTimeout = GatewaySender.MINIMUM_SOCKET_READ_TIMEOUT + 1000;
@@ -320,13 +320,13 @@ public void testCreateDestroyGatewaySender_OnMember() {
320320
*/
321321
@Test
322322
public void testCreateDestroyGatewaySender_Group() {
323-
Integer punePort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
324-
propsSetUp(punePort);
323+
Integer dsIdPort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
324+
propsSetUp(dsIdPort);
325325

326-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
327-
vm3.invoke(() -> createCacheWithGroups(punePort, "SenderGroup1"));
328-
vm4.invoke(() -> createCacheWithGroups(punePort, "SenderGroup1"));
329-
vm5.invoke(() -> createCacheWithGroups(punePort, "SenderGroup1"));
326+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
327+
vm3.invoke(() -> createCacheWithGroups(dsIdPort, "SenderGroup1"));
328+
vm4.invoke(() -> createCacheWithGroups(dsIdPort, "SenderGroup1"));
329+
vm5.invoke(() -> createCacheWithGroups(dsIdPort, "SenderGroup1"));
330330

331331
int socketReadTimeout = GatewaySender.MINIMUM_SOCKET_READ_TIMEOUT + 1000;
332332
String command = CliStrings.CREATE_GATEWAYSENDER + " --" + CliStrings.CREATE_GATEWAYSENDER__ID
@@ -374,13 +374,13 @@ public void testCreateDestroyGatewaySender_Group() {
374374
*/
375375
@Test
376376
public void testCreateDestroyGatewaySender_Group_Scenario2() {
377-
Integer punePort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
378-
propsSetUp(punePort);
377+
Integer dsIdPort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
378+
propsSetUp(dsIdPort);
379379

380-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
381-
vm3.invoke(() -> createCacheWithGroups(punePort, "SenderGroup1"));
382-
vm4.invoke(() -> createCacheWithGroups(punePort, "SenderGroup1"));
383-
vm5.invoke(() -> createCacheWithGroups(punePort, "SenderGroup2"));
380+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
381+
vm3.invoke(() -> createCacheWithGroups(dsIdPort, "SenderGroup1"));
382+
vm4.invoke(() -> createCacheWithGroups(dsIdPort, "SenderGroup1"));
383+
vm5.invoke(() -> createCacheWithGroups(dsIdPort, "SenderGroup2"));
384384

385385
int socketReadTimeout = GatewaySender.MINIMUM_SOCKET_READ_TIMEOUT + 1000;
386386
String command = CliStrings.CREATE_GATEWAYSENDER + " --" + CliStrings.CREATE_GATEWAYSENDER__ID
@@ -425,13 +425,13 @@ public void testCreateDestroyGatewaySender_Group_Scenario2() {
425425
*/
426426
@Test
427427
public void testCreateDestroyParallelGatewaySender() {
428-
Integer punePort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
429-
propsSetUp(punePort);
428+
Integer dsIdPort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
429+
propsSetUp(dsIdPort);
430430

431-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
432-
vm3.invoke(() -> createCache(punePort));
433-
vm4.invoke(() -> createCache(punePort));
434-
vm5.invoke(() -> createCache(punePort));
431+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
432+
vm3.invoke(() -> createCache(dsIdPort));
433+
vm4.invoke(() -> createCache(dsIdPort));
434+
vm5.invoke(() -> createCache(dsIdPort));
435435

436436
int socketReadTimeout = GatewaySender.MINIMUM_SOCKET_READ_TIMEOUT + 1000;
437437
String command = CliStrings.CREATE_GATEWAYSENDER + " --" + CliStrings.CREATE_GATEWAYSENDER__ID

‎geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/CreateGatewayReceiverCommandDUnitTest.java

+60-60
Original file line numberDiff line numberDiff line change
@@ -50,13 +50,13 @@ public class CreateGatewayReceiverCommandDUnitTest extends WANCommandTestBase {
5050
@Test
5151
public void testCreateGatewayReceiverWithDefault() {
5252
VM puneLocator = Host.getLocator();
53-
int punePort = puneLocator.invoke(this::getLocatorPort);
54-
propsSetUp(punePort);
55-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
53+
int dsIdPort = puneLocator.invoke(this::getLocatorPort);
54+
propsSetUp(dsIdPort);
55+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
5656

57-
vm3.invoke(() -> createCache(punePort));
58-
vm4.invoke(() -> createCache(punePort));
59-
vm5.invoke(() -> createCache(punePort));
57+
vm3.invoke(() -> createCache(dsIdPort));
58+
vm4.invoke(() -> createCache(dsIdPort));
59+
vm5.invoke(() -> createCache(dsIdPort));
6060

6161
String command = CliStrings.CREATE_GATEWAYRECEIVER;
6262
CommandResult cmdResult = executeCommand(command);
@@ -96,13 +96,13 @@ public void testCreateGatewayReceiverWithDefault() {
9696
@Test
9797
public void testCreateGatewayReceiver() {
9898
VM puneLocator = Host.getLocator();
99-
int punePort = puneLocator.invoke(this::getLocatorPort);
100-
propsSetUp(punePort);
101-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
99+
int dsIdPort = puneLocator.invoke(this::getLocatorPort);
100+
propsSetUp(dsIdPort);
101+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
102102

103-
vm3.invoke(() -> createCache(punePort));
104-
vm4.invoke(() -> createCache(punePort));
105-
vm5.invoke(() -> createCache(punePort));
103+
vm3.invoke(() -> createCache(dsIdPort));
104+
vm4.invoke(() -> createCache(dsIdPort));
105+
vm5.invoke(() -> createCache(dsIdPort));
106106

107107
String command =
108108
CliStrings.CREATE_GATEWAYRECEIVER + " --" + CliStrings.CREATE_GATEWAYRECEIVER__MANUALSTART
@@ -141,13 +141,13 @@ public void testCreateGatewayReceiver() {
141141
@Test
142142
public void testCreateGatewayReceiverWithGatewayTransportFilter() {
143143
VM puneLocator = Host.getLocator();
144-
int punePort = puneLocator.invoke(this::getLocatorPort);
145-
propsSetUp(punePort);
146-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
144+
int dsIdPort = puneLocator.invoke(this::getLocatorPort);
145+
propsSetUp(dsIdPort);
146+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
147147

148-
vm3.invoke(() -> createCache(punePort));
149-
vm4.invoke(() -> createCache(punePort));
150-
vm5.invoke(() -> createCache(punePort));
148+
vm3.invoke(() -> createCache(dsIdPort));
149+
vm4.invoke(() -> createCache(dsIdPort));
150+
vm5.invoke(() -> createCache(dsIdPort));
151151

152152
String command =
153153
CliStrings.CREATE_GATEWAYRECEIVER + " --" + CliStrings.CREATE_GATEWAYRECEIVER__MANUALSTART
@@ -191,13 +191,13 @@ public void testCreateGatewayReceiverWithGatewayTransportFilter() {
191191
@Test
192192
public void testCreateGatewayReceiverWithMultipleGatewayTransportFilters() {
193193
VM puneLocator = Host.getLocator();
194-
int punePort = puneLocator.invoke(this::getLocatorPort);
195-
propsSetUp(punePort);
196-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
194+
int dsIdPort = puneLocator.invoke(this::getLocatorPort);
195+
propsSetUp(dsIdPort);
196+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
197197

198-
vm3.invoke(() -> createCache(punePort));
199-
vm4.invoke(() -> createCache(punePort));
200-
vm5.invoke(() -> createCache(punePort));
198+
vm3.invoke(() -> createCache(dsIdPort));
199+
vm4.invoke(() -> createCache(dsIdPort));
200+
vm5.invoke(() -> createCache(dsIdPort));
201201

202202
String command = CliStrings.CREATE_GATEWAYRECEIVER + " --"
203203
+ CliStrings.CREATE_GATEWAYRECEIVER__BINDADDRESS + "=localhost" + " --"
@@ -241,13 +241,13 @@ public void testCreateGatewayReceiverWithMultipleGatewayTransportFilters() {
241241
@Test
242242
public void testCreateGatewayReceiver_Error() {
243243
VM puneLocator = Host.getLocator();
244-
int punePort = puneLocator.invoke(this::getLocatorPort);
245-
propsSetUp(punePort);
246-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
244+
int dsIdPort = puneLocator.invoke(this::getLocatorPort);
245+
propsSetUp(dsIdPort);
246+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
247247

248-
vm3.invoke(() -> createCache(punePort));
249-
vm4.invoke(() -> createCache(punePort));
250-
vm5.invoke(() -> createCache(punePort));
248+
vm3.invoke(() -> createCache(dsIdPort));
249+
vm4.invoke(() -> createCache(dsIdPort));
250+
vm5.invoke(() -> createCache(dsIdPort));
251251

252252
String command =
253253
CliStrings.CREATE_GATEWAYRECEIVER + " --" + CliStrings.CREATE_GATEWAYRECEIVER__BINDADDRESS
@@ -280,13 +280,13 @@ public void testCreateGatewayReceiver_Error() {
280280
@Test
281281
public void testCreateGatewayReceiver_onMember() {
282282
VM puneLocator = Host.getLocator();
283-
int punePort = puneLocator.invoke(this::getLocatorPort);
284-
propsSetUp(punePort);
285-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
283+
int dsIdPort = puneLocator.invoke(this::getLocatorPort);
284+
propsSetUp(dsIdPort);
285+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
286286

287-
vm3.invoke(() -> createCache(punePort));
288-
vm4.invoke(() -> createCache(punePort));
289-
vm5.invoke(() -> createCache(punePort));
287+
vm3.invoke(() -> createCache(dsIdPort));
288+
vm4.invoke(() -> createCache(dsIdPort));
289+
vm5.invoke(() -> createCache(dsIdPort));
290290

291291
final DistributedMember vm3Member = vm3.invoke(this::getMember);
292292

@@ -325,13 +325,13 @@ public void testCreateGatewayReceiver_onMember() {
325325
@Test
326326
public void testCreateGatewayReceiver_onMultipleMembers() {
327327
VM puneLocator = Host.getLocator();
328-
int punePort = puneLocator.invoke(this::getLocatorPort);
329-
propsSetUp(punePort);
330-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
328+
int dsIdPort = puneLocator.invoke(this::getLocatorPort);
329+
propsSetUp(dsIdPort);
330+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
331331

332-
vm3.invoke(() -> createCache(punePort));
333-
vm4.invoke(() -> createCache(punePort));
334-
vm5.invoke(() -> createCache(punePort));
332+
vm3.invoke(() -> createCache(dsIdPort));
333+
vm4.invoke(() -> createCache(dsIdPort));
334+
vm5.invoke(() -> createCache(dsIdPort));
335335

336336
final DistributedMember vm3Member = vm3.invoke(this::getMember);
337337
final DistributedMember vm4Member = vm4.invoke(this::getMember);
@@ -372,13 +372,13 @@ public void testCreateGatewayReceiver_onMultipleMembers() {
372372
@Test
373373
public void testCreateGatewayReceiver_onGroup() {
374374
VM puneLocator = Host.getLocator();
375-
int punePort = puneLocator.invoke(this::getLocatorPort);
376-
propsSetUp(punePort);
377-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
375+
int dsIdPort = puneLocator.invoke(this::getLocatorPort);
376+
propsSetUp(dsIdPort);
377+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
378378

379-
vm3.invoke(() -> createCacheWithGroups(punePort, "receiverGroup1"));
380-
vm4.invoke(() -> createCacheWithGroups(punePort, "receiverGroup1"));
381-
vm5.invoke(() -> createCacheWithGroups(punePort, "receiverGroup1"));
379+
vm3.invoke(() -> createCacheWithGroups(dsIdPort, "receiverGroup1"));
380+
vm4.invoke(() -> createCacheWithGroups(dsIdPort, "receiverGroup1"));
381+
vm5.invoke(() -> createCacheWithGroups(dsIdPort, "receiverGroup1"));
382382

383383
String command =
384384
CliStrings.CREATE_GATEWAYRECEIVER + " --" + CliStrings.CREATE_GATEWAYRECEIVER__MANUALSTART
@@ -420,13 +420,13 @@ public void testCreateGatewayReceiver_onGroup() {
420420
@Test
421421
public void testCreateGatewayReceiver_onGroup_Scenario2() {
422422
VM puneLocator = Host.getLocator();
423-
int punePort = puneLocator.invoke(this::getLocatorPort);
424-
propsSetUp(punePort);
425-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
423+
int dsIdPort = puneLocator.invoke(this::getLocatorPort);
424+
propsSetUp(dsIdPort);
425+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
426426

427-
vm3.invoke(() -> createCacheWithGroups(punePort, "receiverGroup1"));
428-
vm4.invoke(() -> createCacheWithGroups(punePort, "receiverGroup1"));
429-
vm5.invoke(() -> createCacheWithGroups(punePort, "receiverGroup2"));
427+
vm3.invoke(() -> createCacheWithGroups(dsIdPort, "receiverGroup1"));
428+
vm4.invoke(() -> createCacheWithGroups(dsIdPort, "receiverGroup1"));
429+
vm5.invoke(() -> createCacheWithGroups(dsIdPort, "receiverGroup2"));
430430

431431
String command =
432432
CliStrings.CREATE_GATEWAYRECEIVER + " --" + CliStrings.CREATE_GATEWAYRECEIVER__MANUALSTART
@@ -464,13 +464,13 @@ public void testCreateGatewayReceiver_onGroup_Scenario2() {
464464
@Test
465465
public void testCreateGatewayReceiver_onMultipleGroups() {
466466
VM puneLocator = Host.getLocator();
467-
int punePort = puneLocator.invoke(this::getLocatorPort);
468-
propsSetUp(punePort);
469-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
467+
int dsIdPort = puneLocator.invoke(this::getLocatorPort);
468+
propsSetUp(dsIdPort);
469+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
470470

471-
vm3.invoke(() -> createCacheWithGroups(punePort, "receiverGroup1"));
472-
vm4.invoke(() -> createCacheWithGroups(punePort, "receiverGroup1"));
473-
vm5.invoke(() -> createCacheWithGroups(punePort, "receiverGroup2"));
471+
vm3.invoke(() -> createCacheWithGroups(dsIdPort, "receiverGroup1"));
472+
vm4.invoke(() -> createCacheWithGroups(dsIdPort, "receiverGroup1"));
473+
vm5.invoke(() -> createCacheWithGroups(dsIdPort, "receiverGroup2"));
474474

475475
String command =
476476
CliStrings.CREATE_GATEWAYRECEIVER + " --" + CliStrings.CREATE_GATEWAYRECEIVER__MANUALSTART

‎geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/CreateGatewaySenderCommandDUnitTest.java

+12-12
Original file line numberDiff line numberDiff line change
@@ -43,13 +43,13 @@ public class CreateGatewaySenderCommandDUnitTest extends WANCommandTestBase {
4343
*/
4444
@Test
4545
public void testCreateGatewaySender_Error() {
46-
Integer punePort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
47-
propsSetUp(punePort);
46+
Integer dsIdPort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
47+
propsSetUp(dsIdPort);
4848

49-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
50-
vm3.invoke(() -> createCache(punePort));
51-
vm4.invoke(() -> createCache(punePort));
52-
vm5.invoke(() -> createCache(punePort));
49+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
50+
vm3.invoke(() -> createCache(dsIdPort));
51+
vm4.invoke(() -> createCache(dsIdPort));
52+
vm5.invoke(() -> createCache(dsIdPort));
5353

5454
int socketReadTimeout = GatewaySender.MINIMUM_SOCKET_READ_TIMEOUT + 1000;
5555
String command = CliStrings.CREATE_GATEWAYSENDER + " --" + CliStrings.CREATE_GATEWAYSENDER__ID
@@ -89,13 +89,13 @@ public void testCreateGatewaySender_Error() {
8989
*/
9090
@Test
9191
public void testCreateParallelGatewaySender_Error() {
92-
Integer punePort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
93-
propsSetUp(punePort);
92+
Integer dsIdPort = vm1.invoke(() -> createFirstLocatorWithDSId(1));
93+
propsSetUp(dsIdPort);
9494

95-
vm2.invoke(() -> createFirstRemoteLocator(2, punePort));
96-
vm3.invoke(() -> createCache(punePort));
97-
vm4.invoke(() -> createCache(punePort));
98-
vm5.invoke(() -> createCache(punePort));
95+
vm2.invoke(() -> createFirstRemoteLocator(2, dsIdPort));
96+
vm3.invoke(() -> createCache(dsIdPort));
97+
vm4.invoke(() -> createCache(dsIdPort));
98+
vm5.invoke(() -> createCache(dsIdPort));
9999

100100
int socketReadTimeout = GatewaySender.MINIMUM_SOCKET_READ_TIMEOUT + 1000;
101101
String command = CliStrings.CREATE_GATEWAYSENDER + " --" + CliStrings.CREATE_GATEWAYSENDER__ID

0 commit comments

Comments
 (0)