import akka.util.Timeout;
import java.util.Collections;
import java.util.Set;
-import javax.annotation.Nonnull;
import org.opendaylight.controller.cluster.schema.provider.RemoteYangTextSourceProvider;
import org.opendaylight.controller.cluster.schema.provider.impl.YangTextSchemaSourceSerializationProxy;
import org.opendaylight.netconf.topology.singleton.messages.YangTextSchemaSourceRequest;
@Override
public Future<YangTextSchemaSourceSerializationProxy> getYangTextSchemaSource(
- @Nonnull final SourceIdentifier sourceIdentifier) {
+ final SourceIdentifier sourceIdentifier) {
final Future<Object> scalaFuture = Patterns.ask(masterRef,
new YangTextSchemaSourceRequest(sourceIdentifier), actorResponseWaitTime);