Spring/spring-test-data-geode
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Change mock GatewayReceiver.getPort() to generate a random port between start and end ports.

Browse Source
This commit is contained in:
John Blum
2021-09-09 10:43:30 -07:00
parent 74da92a993
commit 9dcd1ed8ea
1 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
spring-data-geode-test/src/main/java/org/springframework/data/gemfire/tests/mock/GemFireMockObjectsSupport.java
View File

@@ -57,6 +57,7 @@ import java.util.Map;
import java.util.Objects; import java.util.Objects;
import java.util.Optional; import java.util.Optional;
import java.util.Properties; import java.util.Properties;
import java.util.Random;
import java.util.Set; import java.util.Set;
import java.util.UUID; import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
@@ -1596,7 +1597,16 @@ public abstract class GemFireMockObjectsSupport extends MockObjectsSupport {
when(mockGatewayReceiver.getHost()).thenAnswer(newGetter(hostnameForSenders)); when(mockGatewayReceiver.getHost()).thenAnswer(newGetter(hostnameForSenders));
when(mockGatewayReceiver.getHostnameForSenders()).thenAnswer(newGetter(hostnameForSenders)); when(mockGatewayReceiver.getHostnameForSenders()).thenAnswer(newGetter(hostnameForSenders));
when(mockGatewayReceiver.getMaximumTimeBetweenPings()).thenAnswer(newGetter(maximumTimeBetweenPings)); when(mockGatewayReceiver.getMaximumTimeBetweenPings()).thenAnswer(newGetter(maximumTimeBetweenPings));
when(mockGatewayReceiver.getPort()).thenReturn(0);
when(mockGatewayReceiver.getPort()).thenAnswer(portInvocation -> {
Random randomPort = new Random(System.currentTimeMillis());
int port = startPort.get() + randomPort.nextInt(endPort.get() - startPort.get());;
return port;
});
when(mockGatewayReceiver.getSocketBufferSize()).thenAnswer(newGetter(socketBufferSize)); when(mockGatewayReceiver.getSocketBufferSize()).thenAnswer(newGetter(socketBufferSize));
when(mockGatewayReceiver.getStartPort()).thenAnswer(newGetter(startPort)); when(mockGatewayReceiver.getStartPort()).thenAnswer(newGetter(startPort));