JdbcBatchingDataCaptureService extends JdbcIteratingDataCaptureServiceImpl { public void setBatchWindow(Integer i) { batchWindow = i; } JdbcBatchingDataCaptureService();  JdbcBatchingDataCaptureService(String statement); Integer getBatchWindow(); void setBatchWindow(Integer i); static final int DEFAULT_BATCH_WINDOW; }
@Test public void testService_IterationsLessThanBatch() throws Exception { createDatabase(); JdbcBatchingDataCaptureService service = (JdbcBatchingDataCaptureService) createBasicService(); service.setRowsUpdatedMetadataKey("rowsUpdatedKey"); service.setBatchWindow(10); AdaptrisMessage msg = AdaptrisMessageFactory.getDefaultInstance().newMessage(XML_DOCUMENT); msg.addMetadata(METADATA_KEY, METADATA_VALUE); execute(service, msg); assertEquals("1", msg.getMetadataValue("rowsUpdatedKey")); execute(service, msg); assertEquals("1", msg.getMetadataValue("rowsUpdatedKey")); doBasicCaptureAsserts(2); }