embeddedTime = System.currentTimeMillis();
for (IndexAction action : embeddedActions) {
action.setLatch(embeddedLatch);
this.offer(action, 1000, TimeUnit.SECONDS);
types.add(action.getPayloadClass().getSimpleName());
<BUG>ecount ++;
}</BUG>
embeddedLatch.await(1500, TimeUnit.MILLISECONDS);
embeddedTime = System.currentTimeMillis() - embeddedTime;
Set<String> refreshedIndexes = new HashSet<String>();

embeddedTime = System.currentTimeMillis();
for (IndexAction action : embeddedActions) {
action.setLatch(embeddedLatch);
this.offer(action, 1000, TimeUnit.SECONDS);
types.add(action.getPayloadClass().getSimpleName());
ecount++;
}
embeddedLatch.await(1500, TimeUnit.MILLISECONDS);
embeddedTime = System.currentTimeMillis() - embeddedTime;
Set<String> refreshedIndexes = new HashSet<String>();
