Adaptation to MvStore, multithreaded consumers, retry scheduling

This should be `LoggerFactory.getLogger(DBQueueExample.class);`