Refactored the queue functionality to be based on a service (QueueMonitor.java) in the core project.