Added support for message retry when consumer callbacks return false.