cancelling consumer during kill
merging queue-handling branch