import java.util.List;
import java.util.concurrent.ExecutionException;
import org.junit.Before;
-import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
-import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
+import org.opendaylight.mdsal.binding.api.ReadWriteTransaction;
+import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
import org.opendaylight.protocol.bgp.openconfig.routing.policy.spi.AbstractStatementRegistryTest;
import org.opendaylight.protocol.bgp.openconfig.routing.policy.spi.registry.StatementRegistry;
import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.routing.policy.rev151009.routing.policy.top.routing.policy.PolicyDefinitions;
activator.start(this.statementRegistry);
}
+ @Override
protected List<Statement> loadStatement(final String policyName) throws ExecutionException, InterruptedException {
final ReadWriteTransaction rt = getDataBroker().newReadWriteTransaction();
final PolicyDefinition policy = rt.read(LogicalDatastoreType.CONFIGURATION, ROUTING_POLICY_IID
.get().get();
return policy.getStatements().getStatement();
}
-
}