remove lock
update consumer, process_data_events thread
update helper retry
remove synchronized