streamManager.send("hello world");
streamManager.send("a wonderful world");
streamManager.send("the world says hello");
RuntimeMetrics metrics = RuntimeStats.getFlowletMetrics("WordCount", "WordCounter", "associator");
metrics.waitForProcessed(3, 5, TimeUnit.SECONDS);
<BUG>ServiceManager serviceManager = appManager.startService(RetrieveCounts.SERVICE_NAME);

serviceManager.waitForStatus(true);</BUG>
String response = requestService(new URL(serviceManager.getServiceURL(15, TimeUnit.SECONDS), "stats"));
Map<String, String> map = new Gson().fromJson(response, stringMapType);

streamManager.send("hello world");
streamManager.send("a wonderful world");
streamManager.send("the world says hello");
RuntimeMetrics metrics = RuntimeStats.getFlowletMetrics("WordCount", "WordCounter", "associator");
metrics.waitForProcessed(3, 5, TimeUnit.SECONDS);
ServiceManager serviceManager = appManager.getServiceManager(RetrieveCounts.SERVICE_NAME);
serviceManager.start();
serviceManager.waitForStatus(true);
String response = requestService(new URL(serviceManager.getServiceURL(15, TimeUnit.SECONDS), "stats"));
Map<String, String> map = new Gson().fromJson(response, stringMapType);
