Hi All,

I submited a feature request of providing acknowledgemode expecially client
acknowledge mode whic jira link is
https://issues.apache.org/jira/browse/ROCKETMQ-40?jql=project%20%3D%20ROCKETMQ

And a few days ago ,I submited a pr
https://github.com/apache/incubator-rocketmq/pull/40 for a implemention on
concurrently consuming, which providing a new Interface with a method
called acknowledgementMode(), based on which to decide whether to persist
offset.

Since I am trying not to modify the existing interface to make it compable
with the existing versions, so I created a new listsner called
MessageListenerConcurrentlyV2

This is my rough implementation, any good adivce on this?

Best Regards
Jaskey

Reply via email to