@Override
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
    InvocationData invocationData = new InvocationData();
    invocationData.key = request.getParameter("key");
    invocationData.topic = request.getParameter("topic");
    invocationData.resultsOffset = Integer.parseInt(request.getParameter("results_offset"));
    invocationData.resultsCount = Integer.parseInt(request.getParameter("results_count"));
    String[] ids = request.getParameterValues("id");
    invocationData.subIds = (ids != null) ? Arrays.asList(ids) : new ArrayList<String>();

    if (request.getParameter("document") != null) {
        invocationData.lastReceivedDocument = ProspectiveSearchServiceFactory.getProspectiveSearchService().getDocument(request);
    }
    TestBase.putTempData(invocationData);
}
 

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

@Before
public void setUp() {
    service = ProspectiveSearchServiceFactory.getProspectiveSearchService();
}
 

protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
    Ping ping = new Ping();
    ping.invoked = true;
    ping.lastReceivedDocument = ProspectiveSearchServiceFactory.getProspectiveSearchService().getDocument(request);
    TestBase.putTempData(ping);
}