fix mistakes
wait on save before write, handle error
Consumer: use msgpack stream + various repairs