@Test public void testGetConnector() { when(connectorMgrMock.getSqoopConnector(123l)).thenReturn(sqoopConnectorMock); when(sqoopConnectorMock.getSupportedDirections()).thenReturn(getSupportedDirections()); assertEquals(jobManager.getSqoopConnector(123l), sqoopConnectorMock); verify(connectorMgrMock, times(1)).getSqoopConnector(123l); }
SqoopConnector getSqoopConnector(long connnectorId) { return ConnectorManager.getInstance().getSqoopConnector(connnectorId); }
JobManager implements Reconfigurable { SqoopConnector getSqoopConnector(long connnectorId) { return ConnectorManager.getInstance().getSqoopConnector(connnectorId); } }
JobManager implements Reconfigurable { SqoopConnector getSqoopConnector(long connnectorId) { return ConnectorManager.getInstance().getSqoopConnector(connnectorId); }  }
JobManager implements Reconfigurable { SqoopConnector getSqoopConnector(long connnectorId) { return ConnectorManager.getInstance().getSqoopConnector(connnectorId); }  static JobManager getInstance(); static void setInstance(JobManager newInstance); void setNotificationBaseUrl(String url); String getNotificationBaseUrl(); synchronized void destroy(); synchronized void initialize(); MSubmission start(long jobId, HttpEventContext ctx); JobRequest createJobRequest(long jobId, MSubmission submission); MSubmission createJobSubmission(HttpEventContext ctx, long jobId); void prepareJob(JobRequest request); MSubmission stop(long jobId, HttpEventContext ctx); MSubmission status(long jobId); void updateSubmission(MSubmission submission); @Override synchronized void configurationChanged(); }
JobManager implements Reconfigurable { SqoopConnector getSqoopConnector(long connnectorId) { return ConnectorManager.getInstance().getSqoopConnector(connnectorId); }  static JobManager getInstance(); static void setInstance(JobManager newInstance); void setNotificationBaseUrl(String url); String getNotificationBaseUrl(); synchronized void destroy(); synchronized void initialize(); MSubmission start(long jobId, HttpEventContext ctx); JobRequest createJobRequest(long jobId, MSubmission submission); MSubmission createJobSubmission(HttpEventContext ctx, long jobId); void prepareJob(JobRequest request); MSubmission stop(long jobId, HttpEventContext ctx); MSubmission status(long jobId); void updateSubmission(MSubmission submission); @Override synchronized void configurationChanged();  }