@Test
public void notifyNodeTest() {

    InstanceIdentifier instanceIdentifierMock = mock(InstanceIdentifier.class);
    eventSourceTopic.notifyNode(instanceIdentifierMock);
    verify(eventSourceServiceMock, times(1)).joinTopic(any(JoinTopicInput.class));
}