class PsqlEventSource implements EventSource {

    @Override public void connect() throws DataAccessException {
        if (!isConnected()) {
            connection = connectionProvider.getConnection();
        }
        subscribeToStream();
    }

    public  PsqlEventSource(String dbUrl, String username, String password, String tableName);
    public  PsqlEventSource(String dbUrl, String username, String password, String tableName, boolean autoConfig);
    public  PsqlEventSource(ConnectionProvider connectionProvider, String tableName);
    public  PsqlEventSource(ConnectionProvider connectionProvider, String tableName, boolean autoConfig);
    @VisibleForTesting  PsqlEventSource(ConnectionProvider connectionProvider, String tableName, PsqlEventMapper mapper,
                                       boolean autoConfig);
    @VisibleForTesting public  PsqlEventSource(ConnectionProvider connectionProvider, String tableName, PsqlEventMapper mapper,
                           boolean autoConfig, PsqlConfigurator configurator);

}