@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();
}