MysqlEventSource implements EventSource { @Override public boolean isConnected() { try { return (connection != null && listener != null && !connection.isClosed()); } catch (SQLException e) { return false; } } MysqlEventSource(ConnectionProvider connectionProvider, String tableName); @VisibleForTesting  MysqlEventSource(ConnectionProvider connectionProvider, String tableName, MysqlConfigurator 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 = INTEGRATION) public void testIsConnectedReturnsFalseBeforeConnection() { MysqlEventSource eventSource = new MysqlEventSource(provider, TEST_TABLE_NAME); assertFalse(eventSource.isConnected()); }