private String getContainerWithPid(URL url) {
		String result = containerLogLocation;
		if (result.contains("[PID]")) {
			Integer[] pids = null;
			if (isOnEc2) {
				pids = StreamUtils.getContainerPidsFromURL(url, xdEnvironment.getPrivateKey(),
						jpsCommand);
			}
			else {
				pids = StreamUtils.getLocalContainerPids(jpsCommand);
			}
			//Supports one container per server or virtual instance.
			if (pids.length > 0) {
				String pid = pids[0].toString();
				result = StringUtils.replace(containerLogLocation, "[PID]", pid);
			}
		}
		return result;
	}
Asserts that the expected number (or greater than or equal to the expected number) of messages were processed by
the modules in the stream. Also asserts that no errors occurred.

@param modules The list of modules to evaluate.
@param msgCountExpected The expected count
@param greaterThanOrEqualTo true if should use greaterThanOrEqualToComparison
spring-xd-integration-test/src/main/java/org/springframework/xd/integration/util/XdEc2Validation.java