class MysqlEventSource implements EventSource {

    @Override
    public boolean isConnected() {
        try {
            return (connection != null && listener != null && !connection.isClosed());
        } catch (SQLException e) {
            return false;
        }
    }

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

}