add  consume result callback
add retry
working queue