Feature/keepprocessing

refactor fetch.
do not interrupt processing of incoming queue if one message fails.