Work queue system in which the worker classes decide which messages to process. - View it on GitHub