Consumer defines an interface for blocking action for listening for incoming events and invoking handler on each of them when Consumer returns, it is always one of Error defined values wrapped.

MessageHandler is called to handle message found by Consumer.

MessageHandlerFunc is a function implementing MessageHandler interface.