+ @Test
+ public void destroyTopicTest() throws Exception {
+ topicTestHelper();
+ TopicId topicId = new TopicId("topic-id-007");
+ Map<TopicId, EventSourceTopic> localMap = eventSourceTopology.getEventSourceTopicMap();
+ EventSourceTopic eventSourceTopic = EventSourceTopic.create(new NotificationPattern("foo"),
+ "pattern", eventSourceTopology);
+ localMap.put(topicId, eventSourceTopic);
+ DestroyTopicInput input = new DestroyTopicInputBuilder().setTopicId(topicId).build();
+ eventSourceTopology.destroyTopic(input);
+ verify(listenerRegistrationMock, times(1)).close();
+ }
+
+ private void topicTestHelper() throws Exception {