8687888990919293949596
{ final Message m = (Message) iter.nextElement(); if (m != null) { messageStore.store(m); if (++messagesRead % commitInterval == 0) { messageStore.checkpoint(); }