This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a change to branch OpenMessaging
in repository https://gitbox.apache.org/repos/asf/rocketmq-ons.git.
from 192acc0 Merge pull request #12 from duhenglucky/OpenMessaging
new 1e95020 feat(PullConsumer) add seek to begin/end support
new 3736c07 feat(PullConsumer) add seek to begin/end support
new 0d9f225 Merge pull request #14 from duhenglucky/OpenMessaging
The 39 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../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(-)
