Started implementing some abstract queue and message bus services.