@Hellojungle pullMessage and consumeMessage are both useful, and worth to be implemented. Use PullConsumer to implement the pullMessage(just rename the old consumeMessage command to pullMessage). Use PushConsumer to implement a new consumeMessage command, which will ack the offsets to broker automatically(Maybe this should be configurable).
[ Full content available at: https://github.com/apache/rocketmq/pull/454 ] This message was relayed via gitbox.apache.org for [email protected]
