+ doReturn(RpcResultBuilder.success(new JoinTopicOutputBuilder().setStatus(JoinTopicStatus.Up).build())
+ .buildFuture()).when(eventSourceServiceMock).joinTopic(any(JoinTopicInput.class));
+
+ eventSourceTopologyMock = mock(EventSourceTopology.class);
+ dataBrokerMock = mock(DataBroker.class);
+ doReturn(eventSourceServiceMock).when(eventSourceTopologyMock).getEventSourceService();
+ doReturn(dataBrokerMock).when(eventSourceTopologyMock).getDataBroker();
+
+ WriteTransaction writeTransactionMock = mock(WriteTransaction.class);
+ doReturn(writeTransactionMock).when(dataBrokerMock).newWriteOnlyTransaction();
+ doNothing().when(writeTransactionMock).mergeParentStructurePut(any(LogicalDatastoreType.class),
+ any(InstanceIdentifier.class), any(DataObject.class));
+ FluentFuture checkedFutureWriteMock = mock(FluentFuture.class);
+ doReturn(checkedFutureWriteMock).when(writeTransactionMock).commit();
+
+ ReadTransaction readOnlyTransactionMock = mock(ReadTransaction.class);
+ doReturn(readOnlyTransactionMock).when(dataBrokerMock).newReadOnlyTransaction();
+ FluentFuture checkedFutureReadMock = mock(FluentFuture.class);
+ doReturn(checkedFutureReadMock).when(readOnlyTransactionMock).read(LogicalDatastoreType.OPERATIONAL,
+ EventSourceTopology.EVENT_SOURCE_TOPOLOGY_PATH);
+ eventSourceTopic = EventSourceTopic.create(notificationPattern, "nodeIdPattern1", eventSourceTopologyMock);