refactor consumers
go fmt
fix bug I introduced in qrem