pub trait QueueIterator<V: InternalMessageValue>: Send {
// Required methods
fn next(&mut self, with_new: bool) -> Result<Option<IterItem<V>>>;
fn current_position(&self) -> FastHashMap<ShardIdent, QueueKey>;
fn process_new_messages(&mut self) -> Result<Option<IterItem<V>>>;
}