Hello!

Am looking to implement middleware for a consumer handler, but can't see a way of doing this currently, as the HandlerMiddleware has an interface of func(h HandlerFunc) HandlerFunc and a HandlerFunc has an interface of func(msg *Message) ([]*Message, error), whereas the NoPublishHandlerFunc has an interface of func(msg *Message) error.

Is there a recommended pattern for implementing middleware for consumer handlers?

Thanks!