import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker;
import org.opendaylight.netconf.notifications.NetconfNotificationCollector;
import org.opendaylight.netconf.notifications.NotificationRegistration;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.netconf.notification._1._0.rev080714.StreamNameType;
public void setUp() throws Exception {
MockitoAnnotations.initMocks(this);
final NetconfNotificationCollector notificationCollector = mock(NetconfNotificationCollector.class);
- final BindingAwareBroker.ProviderContext session = mock(BindingAwareBroker.ProviderContext.class);
doReturn(notificationRegistration).when(notificationCollector).registerStreamListener(any(
NetconfNotificationCollector.NetconfNotificationStreamListener.class));
- doReturn(dataBroker).when(session).getSALService(DataBroker.class);
WriteTransaction tx = mock(WriteTransaction.class);
doNothing().when(tx).merge(any(LogicalDatastoreType.class), any(InstanceIdentifier.class),
import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker;
import org.opendaylight.controller.sal.core.api.model.SchemaService;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Uri;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160409.ModulesState;
@Mock
private SchemaService schemaService;
@Mock
- private BindingAwareBroker.ProviderContext context;
- @Mock
private DataBroker dataBroker;
@Mock
private WriteTransaction writeTransaction;
public void setUp() {
MockitoAnnotations.initMocks(this);
- when(context.getSALService(DataBroker.class)).thenReturn(dataBroker);
when(dataBroker.newWriteOnlyTransaction()).thenReturn(writeTransaction);
doNothing().when(writeTransaction).put(eq(LogicalDatastoreType.OPERATIONAL), any(), any());
when(writeTransaction.submit()).thenReturn(Futures.immediateCheckedFuture(null));
return new ModulesStateBuilder().setModuleSetId("0")
.setModule(Lists.newArrayList(module)).build();
}
-}
\ No newline at end of file
+}
import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
import org.opendaylight.controller.md.sal.common.api.data.TransactionChainListener;
import org.opendaylight.controller.md.sal.dom.api.DOMMountPointService;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker;
import org.opendaylight.netconf.sal.connect.util.RemoteDeviceId;
public class NetconfDeviceSalProviderTest {
@Mock
private DOMMountPointService mountpointService;
@Mock
- private BindingAwareBroker.ProviderContext context;
- @Mock
private WriteTransaction tx;
@Mock
private DataBroker dataBroker;
doReturn(Futures.immediateCheckedFuture(null)).when(writeTx).submit();
provider = new NetconfDeviceSalProvider(new RemoteDeviceId("device1",
InetSocketAddress.createUnresolved("localhost", 17830)), mountPointService, dataBroker);
- when(context.getSALService(DataBroker.class)).thenReturn(dataBroker);
when(chain.newWriteOnlyTransaction()).thenReturn(tx);
when(tx.submit()).thenReturn(Futures.immediateCheckedFuture(null));
when(tx.getIdentifier()).thenReturn(tx);