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