+ final DOMDataBroker slaveDOMDataBroker = domDataBrokerCaptor.getValue();
+ assertTrue(slaveDOMDataBroker instanceof ProxyDOMDataBroker);
+
+ slaveDOMDataBroker.newReadOnlyTransaction();
+ verify(mockDOMDataBroker).newReadOnlyTransaction();
+
+ slaveDOMDataBroker.newReadWriteTransaction();
+ verify(mockDOMDataBroker).newReadWriteTransaction();
+
+ slaveDOMDataBroker.newWriteOnlyTransaction();
+ verify(mockDOMDataBroker).newWriteOnlyTransaction();
+ }
+
+ private ActorRef registerSlaveMountPoint() {
+ final ActorRef slaveRef = system.actorOf(NetconfNodeActor.props(
+ NetconfTopologySetupBuilder.create().setActorSystem(system).build(), remoteDeviceId, mockRegistry,
+ mockSchemaRepository, TIMEOUT, mockMountPointService));
+
+ doReturn(Futures.immediateFuture(mockSchemaContext))
+ .when(mockSchemaContextFactory).createSchemaContext(any());
+
+ slaveRef.tell(new RegisterMountPoint(ImmutableList.of(SOURCE_IDENTIFIER1, SOURCE_IDENTIFIER2),
+ masterRef), testKit.getRef());
+
+ verify(mockMountPointBuilder, timeout(5000)).register();
+ verify(mockMountPointBuilder).addInitialSchemaContext(mockSchemaContext);
+ verify(mockMountPointBuilder).addService(eq(DOMDataBroker.class), any());
+ verify(mockMountPointBuilder).addService(eq(DOMRpcService.class), any());
+ verify(mockMountPointBuilder).addService(eq(DOMNotificationService.class), any());
+
+ testKit.expectMsgClass(Success.class);
+
+ return slaveRef;
+ }
+
+ private void initializeMaster(List<SourceIdentifier> sourceIdentifiers) {
+ masterRef.tell(new CreateInitialMasterActorData(mockDOMDataBroker, sourceIdentifiers,
+ mockDOMRpcService), testKit.getRef());
+
+ testKit.expectMsgClass(MasterActorDataInitialized.class);
+ }
+
+ private void resetMountPointMocks() {
+ reset(mockMountPointReg, mockMountPointBuilder);
+
+ doNothing().when(mockMountPointReg).close();
+
+ doReturn(mockMountPointBuilder).when(mockMountPointBuilder).addInitialSchemaContext(any());
+ doReturn(mockMountPointBuilder).when(mockMountPointBuilder).addService(any(), any());
+ doReturn(mockMountPointReg).when(mockMountPointBuilder).register();