This is an automated email from the ASF dual-hosted git repository. duhengforever pushed a commit to branch OpenMessaging in repository https://gitbox.apache.org/repos/asf/rocketmq-ons.git
commit 0d9f225699fe804d0a8b93e516580a1783c3c2b4 Merge: 192acc0 3736c07 Author: Heng Du <[email protected]> AuthorDate: Mon Nov 25 20:23:21 2019 +0800 Merge pull request #14 from duhenglucky/OpenMessaging feat(PullConsumer) add seek to begin/end support .../org/apache/rocketmq/ons/api/Constants.java | 2 + .../apache/rocketmq/ons/api/PropertyKeyConst.java | 1 + .../apache/rocketmq/ons/api/bean/ConsumerBean.java | 33 +++----------- .../ons/api/impl/rocketmq/PullConsumerImpl.java | 50 ++++++++-------------- ons-core/pom.xml | 2 +- .../ons/sample/consumer/SimplePullConsumer.java | 7 +-- .../ons/sample/producer/MQTimerProducer.java | 1 + .../ons/sample/producer/SimpleMQProducer.java | 1 - .../sample/producer/SimpleTransactionProducer.java | 2 +- 9 files changed, 36 insertions(+), 63 deletions(-)
