import com.google.common.base.Preconditions;
import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
+import com.google.common.util.concurrent.MoreExecutors;
import java.util.Collection;
import java.util.function.Consumer;
import javax.annotation.Nullable;
}
/**
- * Invoke using blueprint
+ * Invoked using blueprint.
*/
@Override
public void close() {
- runTransaction((tx) -> tx.delete(LogicalDatastoreType.OPERATIONAL, InstanceIdentifier.create(NetconfState.class)));
+ runTransaction((tx) -> tx.delete(LogicalDatastoreType.OPERATIONAL,
+ InstanceIdentifier.create(NetconfState.class)));
}
@Override
@Override
public void onCapabilitiesChanged(Capabilities capabilities) {
- runTransaction((tx) -> tx.put(LogicalDatastoreType.OPERATIONAL, CAPABILITIES_INSTANCE_IDENTIFIER, capabilities));
+ runTransaction((tx) -> tx.put(LogicalDatastoreType.OPERATIONAL, CAPABILITIES_INSTANCE_IDENTIFIER,
+ capabilities));
}
@Override
}
/**
- * Invoke using blueprint
+ * Invoked using blueprint.
*/
public void start() {
serverMonitoringDependency.registerCapabilitiesListener(this);
}
@Override
- public void onFailure(Throwable t) {
- LOG.warn("Unable to update netconf state", t);
+ public void onFailure(Throwable throwable) {
+ LOG.warn("Unable to update netconf state", throwable);
}
- });
+ }, MoreExecutors.directExecutor());
}
private static void updateSessions(WriteTransaction tx, Collection<Session> sessions) {