class MysqlEventSource implements EventSource {

    @Override
    public void connect() throws DataAccessException {
        if (!isConnected()) {
            connection = connectionProvider.getConnection();
            listener = listenerRepo.insert(new Listener(tableName), connection);
        }
    }

    public  MysqlEventSource(ConnectionProvider connectionProvider, String tableName);
    @VisibleForTesting  MysqlEventSource(ConnectionProvider connectionProvider, String tableName, MysqlConfigurator configurator);

}