+ 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);