@Test public void testCreateAndAddRequestState() throws Exception { helpAssureOneState(); assertEquals("Expected size of 1", 1, csm.size()); }
int size() { return requestStates.size(); }
ConnectorManager { int size() { return requestStates.size(); } }
ConnectorManager { int size() { return requestStates.size(); } ConnectorManager(String translatorName, String connectionName);  ConnectorManager(String translatorName, String connectionName, ExecutionFactory<Object, Object> ef); }
ConnectorManager { int size() { return requestStates.size(); } ConnectorManager(String translatorName, String connectionName);  ConnectorManager(String translatorName, String connectionName, ExecutionFactory<Object, Object> ef); String getStausMessage(); List<FunctionMethod> getPushDownFunctions(); SourceCapabilities getCapabilities(); ConnectorWork registerRequest(AtomicRequestMessage message); void start(); void stop(); ExecutionFactory<Object, Object> getExecutionFactory(); Object getConnectionFactory(); String getTranslatorName(); String getConnectionName(); List<String> getId(); }
ConnectorManager { int size() { return requestStates.size(); } ConnectorManager(String translatorName, String connectionName);  ConnectorManager(String translatorName, String connectionName, ExecutionFactory<Object, Object> ef); String getStausMessage(); List<FunctionMethod> getPushDownFunctions(); SourceCapabilities getCapabilities(); ConnectorWork registerRequest(AtomicRequestMessage message); void start(); void stop(); ExecutionFactory<Object, Object> getExecutionFactory(); Object getConnectionFactory(); String getTranslatorName(); String getConnectionName(); List<String> getId();  }