### Question:
TimeWindowProcessMessage implements ProcessMessage { @Override public void processMessage(Row row) { synchronized (rowTemporalStore) { rowTemporalStore.add(row); } } TimeWindowProcessMessage(ConnectorQueryData queryData, ResultsetCreator resultsetCreator); @Override void processMessage(Row row); @Override void end(); void sendMessages();  }### Answer:
@Test @Ignore public void testProcessMessage() throws Exception { time = System.currentTimeMillis(); while (System.currentTimeMillis() - time - 1000 < EJECUTION_TIME * 1000) { Row row = mock(Row.class); timeWindowProcessMessage.processMessage(row); } verify(resultSetCreator, times(EJECUTION_TIME / NUM_TIME_UNITS)).send(); }