Fix data consumber to cope with error conditions correctly such as the device going away