PsqlEventSource implements EventSource { @Override public void cleanup() { if (autoConfig) { configurator.cleanup(); } } PsqlEventSource(String dbUrl, String username, String password, String tableName);  PsqlEventSource(String dbUrl, String username, String password, String tableName, boolean autoConfig);  PsqlEventSource(ConnectionProvider connectionProvider, String tableName);  PsqlEventSource(ConnectionProvider connectionProvider, String tableName, boolean autoConfig); @VisibleForTesting  PsqlEventSource(ConnectionProvider connectionProvider, String tableName, PsqlEventMapper mapper,
                                       boolean autoConfig); @VisibleForTesting  PsqlEventSource(ConnectionProvider connectionProvider, String tableName, PsqlEventMapper mapper,
                           boolean autoConfig, PsqlConfigurator configurator); @Override List<Event<Map<String, Object>>> getNewEvents(); @Override void connect(); @Override void disconnect(); @Override boolean isConnected(); @Override void setup(); @Override void cleanup();  }
@Test(groups = SMALL) public void testReactiveDataSourceDoesntAutoCleanupTheDbIfInitializedWithFalse() { PsqlConfigurator configurator = mock(PsqlConfigurator.class); eventSource = new PsqlEventSource(connectionProvider, TABLE_NAME, new PsqlEventMapper(), NO_AUTO_CONFIG, configurator); eventSource.cleanup(); verify(configurator, never()).cleanup(); }
@Test(groups = SMALL) public void testReactiveDataSourceDoesAutoCleanupTheDbIfInitializedWithTrue() { PsqlConfigurator configurator = mock(PsqlConfigurator.class); eventSource = new PsqlEventSource(connectionProvider, TABLE_NAME, new PsqlEventMapper(), WITH_AUTO_CONFIG, configurator); eventSource.cleanup(); verify(configurator).cleanup(); }