A concurrent blocking queue implementer that writes entries to disk (using OrientDB).  This way if the VM is terminated for any reason, entries are restored on startup.