- final long now = currentTime();
- final Iterator<ConnectionEntry> it = queue.asIterable().iterator();
- while (it.hasNext()) {
- final ConnectionEntry e = it.next();
- forwarder.forwardEntry(e, now);
- it.remove();
- }
-
- queue.setForwarder(forwarder);