Support user-provided timeouts in intra-cluster communication service
Change-Id: I4ed9cd2e84df83b45ae17af24b9780b9ac97a95d
diff --git a/core/net/src/test/java/org/onosproject/cluster/impl/TestClusterCommunicationService.java b/core/net/src/test/java/org/onosproject/cluster/impl/TestClusterCommunicationService.java
index 680ddd0..c273f43 100644
--- a/core/net/src/test/java/org/onosproject/cluster/impl/TestClusterCommunicationService.java
+++ b/core/net/src/test/java/org/onosproject/cluster/impl/TestClusterCommunicationService.java
@@ -15,6 +15,7 @@
*/
package org.onosproject.cluster.impl;
+import java.time.Duration;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.CompletableFuture;
@@ -83,7 +84,8 @@
MessageSubject subject,
Function<M, byte[]> encoder,
Function<byte[], R> decoder,
- NodeId toNodeId) {
+ NodeId toNodeId,
+ Duration duration) {
TestClusterCommunicationService node = nodes.get(toNodeId);
if (node == null) {
return Tools.exceptionalFuture(new MessagingException.NoRemoteHandler());