+ 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).put(any(LogicalDatastoreType.class),
+ any(InstanceIdentifier.class), any(DataObject.class),eq(true));
+ CheckedFuture checkedFutureWriteMock = mock(CheckedFuture.class);
+ doReturn(checkedFutureWriteMock).when(writeTransactionMock).submit();
+
+ ReadOnlyTransaction readOnlyTransactionMock = mock(ReadOnlyTransaction.class);
+ doReturn(readOnlyTransactionMock).when(dataBrokerMock).newReadOnlyTransaction();
+ CheckedFuture checkedFutureReadMock = mock(CheckedFuture.class);
+ doReturn(checkedFutureReadMock).when(readOnlyTransactionMock).read(LogicalDatastoreType.OPERATIONAL,
+ EventSourceTopology.EVENT_SOURCE_TOPOLOGY_PATH);
+ eventSourceTopic = EventSourceTopic.create(notificationPattern, "nodeIdPattern1", eventSourceTopologyMock);