JdbcAsyncWriter extends AbstractJdbcCallback implements AsyncEventListener { @Override public boolean processEvents(@SuppressWarnings("rawtypes") List<AsyncEvent> events) { changeTotalEvents(events.size()); if (!events.isEmpty()) { try { checkInitialized(events.get(0).getRegion()); } catch (RuntimeException ex) { changeFailedEvents(events.size()); logger.error("Exception initializing JdbcAsyncWriter", ex); return true; } } Boolean initialPdxReadSerialized = cache.getPdxReadSerializedOverride(); cache.setPdxReadSerializedOverride(true); try { processEventsList(events); } finally { cache.setPdxReadSerializedOverride(initialPdxReadSerialized); } return true; } @SuppressWarnings("unused")  JdbcAsyncWriter();   JdbcAsyncWriter(SqlHandler sqlHandler, InternalCache cache); @Override boolean processEvents(@SuppressWarnings("rawtypes") List<AsyncEvent> events);  }
@Test public void throwsNullPointerExceptionIfGivenNullList() { assertThatThrownBy(() -> writer.processEvents(null)).isInstanceOf(NullPointerException.class); }