@Test public void testAgentHasJobButNotThisOne() { HarvestAgentStatusDTO harvestAgentStatusDTO = new HarvestAgentStatusDTO(); HashMap<String, HarvesterStatusDTO> statusMap = Maps.newHashMap(); HarvesterStatusDTO harvesterStatusDTO = new HarvesterStatusDTO(); harvesterStatusDTO.setJobName("notTheSameJob"); statusMap.put("irrelevant", harvesterStatusDTO); harvestAgentStatusDTO.setHarvesterStatus(statusMap); boolean result = underTest.agentHasJob("test", harvestAgentStatusDTO); assertFalse(result); }
boolean agentHasJob(String aJobName, HarvestAgentStatusDTO agentStatus) { for (Object hsObject : agentStatus.getHarvesterStatus().values()) { HarvesterStatusDTO harvesterStatus = (HarvesterStatusDTO) hsObject; if (harvesterStatus.getJobName().equals(aJobName)) { return true; } } return false; }
HarvestAgentManagerImpl implements HarvestAgentManager { boolean agentHasJob(String aJobName, HarvestAgentStatusDTO agentStatus) { for (Object hsObject : agentStatus.getHarvesterStatus().values()) { HarvesterStatusDTO harvesterStatus = (HarvesterStatusDTO) hsObject; if (harvesterStatus.getJobName().equals(aJobName)) { return true; } } return false; } }
HarvestAgentManagerImpl implements HarvestAgentManager { boolean agentHasJob(String aJobName, HarvestAgentStatusDTO agentStatus) { for (Object hsObject : agentStatus.getHarvesterStatus().values()) { HarvesterStatusDTO harvesterStatus = (HarvesterStatusDTO) hsObject; if (harvesterStatus.getJobName().equals(aJobName)) { return true; } } return false; }  }
HarvestAgentManagerImpl implements HarvestAgentManager { boolean agentHasJob(String aJobName, HarvestAgentStatusDTO agentStatus) { for (Object hsObject : agentStatus.getHarvesterStatus().values()) { HarvesterStatusDTO harvesterStatus = (HarvesterStatusDTO) hsObject; if (harvesterStatus.getJobName().equals(aJobName)) { return true; } } return false; }  @Override void heartbeat(HarvestAgentStatusDTO aStatus); @Override void updateProfileOverrides(TargetInstance aTargetInstance, String profileString); @Override void pause(TargetInstance aTargetInstance); @Override void resume(TargetInstance aTargetInstance); @Override void abort(TargetInstance aTargetInstance); @Override void stop(TargetInstance aTargetInstance); @Override void pauseAll(); @Override void resumeAll(); @Override LogReader getLogReader(TargetInstance aTargetInstance); @Override void pauseAgent(String agentName); @Override void resumeAgent(String agentName); @Override boolean runningOrPaused(TargetInstance aTargetInstance); @Override void restrictBandwidthFor(TargetInstance targetInstance); @Override List<HarvestAgentStatusDTO> getHarvestersForAgency(String agencyName); @Override void markDead(HarvestAgentStatusDTO agent); @Override void initiateHarvest(HarvestAgentStatusDTO aHarvestAgent, TargetInstance aTargetInstance, String profile,
			String seedsString); @Override void recoverHarvests(String haHost, int haPort, String haService, List<String> activeJobs); @Override boolean lock(Long tiOid); @Override void unLock(Long tiOid); @Override HashMap<String, HarvestAgentStatusDTO> getHarvestAgents(); void setTargetInstanceManager(TargetInstanceManager targetInstanceManager); void setHarvestAgentFactory(HarvestAgentFactory harvestAgentFactory); void setTargetInstanceDao(TargetInstanceDAO targetInstanceDao); @Override void purgeAbortedTargetInstances(String[] tiNames); @Override List<HarvestAgentStatusDTO> getAvailableHarvesters(String agencyName); @Override HarvestAgentStatusDTO getHarvester(String agencyName, String harvesterType); }
HarvestAgentManagerImpl implements HarvestAgentManager { boolean agentHasJob(String aJobName, HarvestAgentStatusDTO agentStatus) { for (Object hsObject : agentStatus.getHarvesterStatus().values()) { HarvesterStatusDTO harvesterStatus = (HarvesterStatusDTO) hsObject; if (harvesterStatus.getJobName().equals(aJobName)) { return true; } } return false; }  @Override void heartbeat(HarvestAgentStatusDTO aStatus); @Override void updateProfileOverrides(TargetInstance aTargetInstance, String profileString); @Override void pause(TargetInstance aTargetInstance); @Override void resume(TargetInstance aTargetInstance); @Override void abort(TargetInstance aTargetInstance); @Override void stop(TargetInstance aTargetInstance); @Override void pauseAll(); @Override void resumeAll(); @Override LogReader getLogReader(TargetInstance aTargetInstance); @Override void pauseAgent(String agentName); @Override void resumeAgent(String agentName); @Override boolean runningOrPaused(TargetInstance aTargetInstance); @Override void restrictBandwidthFor(TargetInstance targetInstance); @Override List<HarvestAgentStatusDTO> getHarvestersForAgency(String agencyName); @Override void markDead(HarvestAgentStatusDTO agent); @Override void initiateHarvest(HarvestAgentStatusDTO aHarvestAgent, TargetInstance aTargetInstance, String profile,
			String seedsString); @Override void recoverHarvests(String haHost, int haPort, String haService, List<String> activeJobs); @Override boolean lock(Long tiOid); @Override void unLock(Long tiOid); @Override HashMap<String, HarvestAgentStatusDTO> getHarvestAgents(); void setTargetInstanceManager(TargetInstanceManager targetInstanceManager); void setHarvestAgentFactory(HarvestAgentFactory harvestAgentFactory); void setTargetInstanceDao(TargetInstanceDAO targetInstanceDao); @Override void purgeAbortedTargetInstances(String[] tiNames); @Override List<HarvestAgentStatusDTO> getAvailableHarvesters(String agencyName); @Override HarvestAgentStatusDTO getHarvester(String agencyName, String harvesterType);  }