}
@Test
public void testTopicIsCreatedWhenFirstSubscriptionForTopicIsCreated() {
ProspectiveSearchService pss = ProspectiveSearchServiceFactory.getProspectiveSearchService();
pss.subscribe(TOPIC, "mySubscription", 0, "title:hello", createSchema("title", FieldType.STRING));
assertTopicExists(TOPIC);
}
@Test
public void testTopicIsRemovedWhenLastSubscriptionForTopicIsDeleted() {