XmlRpcResourceManagerClient implements ResourceManagerClient { @Override public int getJobQueueCapacity() throws JobRepositoryException { try { Vector argList = new Vector(); return ((Integer) client.execute("resourcemgr.getJobQueueCapacity", argList)); } catch (Exception e) { throw new JobRepositoryException("Failed to get JobQueue capacity from server : " + e.getMessage(), e); } } XmlRpcResourceManagerClient(URL url); static void main(String[] args); @Override boolean isJobComplete(String jobId); @Override Job getJobInfo(String jobId); @Override boolean isAlive(); @Override int getJobQueueSize(); @Override int getJobQueueCapacity(); @Override boolean killJob(String jobId); @Override String getExecutionNode(String jobId); @Override String submitJob(Job exec, JobInput in); @Override boolean submitJob(Job exec, JobInput in, URL hostUrl); @Override List getNodes(); @Override ResourceNode getNodeById(String nodeId); @Override URL getResMgrUrl(); @Override void setResMgrUrl(URL resMgrUrl); @Override void addQueue(String queueName); @Override void removeQueue(String queueName); @Override void addNode(ResourceNode node); @Override void removeNode(String nodeId); @Override void setNodeCapacity(String nodeId, int capacity); @Override void addNodeToQueue(String nodeId, String queueName); @Override void removeNodeFromQueue(String nodeId, String queueName); @Override List<String> getQueues(); @Override List<String> getNodesInQueue(String queueName); @Override List<String> getQueuesWithNode(String nodeId); @Override String getNodeLoad(String nodeId); @Override List getQueuedJobs(); @Override String getNodeReport(); String getExecReport(); static String getReadableJobStatus(String status); static final int VAL; static final int INT; static final int VAL1; static final int INT1; }
@Test public void testJobQueueCapacity() throws JobRepositoryException { int capacity = rmc.getJobQueueCapacity(); assertThat(capacity, equalTo(1000)); }