Since a single "interceptor" instance might be added to multiple consumers/producers, it might be good to also pass a reference to the `Consumer`. eg:
```java Message<T> beforeConsume(Consumer<T> consumer, Message<T> message); ``` (This for all methods, also on `ProducerInterceptor`) [ Full content available at: https://github.com/apache/incubator-pulsar/pull/2471 ] This message was relayed via gitbox.apache.org for [email protected]
