package org.opendaylight.protocol.bgp.rib.impl;
import com.google.common.collect.Lists;
+import com.google.common.util.concurrent.Futures;
+import com.google.common.util.concurrent.ListenableFuture;
import com.google.common.util.concurrent.Uninterruptibles;
import java.util.List;
import java.util.concurrent.CountDownLatch;
}
@Override
- public void releaseConnection() {
+ public ListenableFuture<Void> releaseConnection() {
LOG.debug("Releasing connection");
if (this.session != null) {
try {
LOG.warn("Error closing session", e);
}
}
+ return Futures.immediateFuture(null);
}
BGPSessionImpl.State getState() {