synchronized(this.set) {
this.set.remove(info);
}
if (log.isLoggable(Level.FINE)) this.log.fine("run: shuffling for subject '" + info.getId() + "' starts");
info.forwardToSessionQueue();
if (log.isLoggable(Level.FINE)) this.log.fine("run: shuffling for subject '" + info.getId() + "' completed");
}
catch (InterruptedException ex) {
log.severe("run InterruptedException occured " + ex.getMessage());
ex.printStackTrace();