Removed usage of deprecated method
Change-Id: I896fd7db68a0c86893423548bc0a3489ac42ac77
diff --git a/core/store/dist/src/main/java/org/onosproject/store/flow/impl/DistributedFlowRuleStore.java b/core/store/dist/src/main/java/org/onosproject/store/flow/impl/DistributedFlowRuleStore.java
index a259c26..b3a2e36 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/flow/impl/DistributedFlowRuleStore.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/flow/impl/DistributedFlowRuleStore.java
@@ -590,15 +590,12 @@
log.trace("Forwarding removeFlowRule to {}, which is the master for device {}",
master, deviceId);
- return Futures.get(clusterCommunicator.sendAndReceive(
+ return Futures.getUnchecked(clusterCommunicator.sendAndReceive(
rule,
REMOVE_FLOW_ENTRY,
SERIALIZER::encode,
SERIALIZER::decode,
- master),
- FLOW_RULE_STORE_TIMEOUT_MILLIS,
- TimeUnit.MILLISECONDS,
- RuntimeException.class);
+ master));
}
private FlowRuleEvent removeFlowRuleInternal(FlowEntry rule) {