Implements broker monitor (queue length, etc.) #26, #59