@Test
public void testForceDispatch() throws Exception {

    List<Packet> dryRunData = Collections.synchronizedList(new ArrayList<Packet>());
    mDispatcher.setDryRunTarget(dryRunData);
    mDispatcher.setDispatchInterval(-1L);
    final int threadCount = 10;
    final int queryCount = 10;
    final List<String> createdEvents = Collections.synchronizedList(new ArrayList<String>());
    launchTestThreads(mApiUrl, mDispatcher, threadCount, queryCount, createdEvents);
    TestHelper.sleep(500);
    assertEquals(threadCount * queryCount, createdEvents.size());
    assertEquals(0, dryRunData.size());
    mDispatcher.forceDispatch();
    checkForMIAs(threadCount * queryCount, createdEvents, dryRunData);
}