This is an automated email from the ASF dual-hosted git repository.
dinglei pushed a change to branch ctypes
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-python.git.
from 03f524c Merge pull request #62 from messense/docker-master
new 7a55078 feat(producer) add sharding key order message support
new e647d64 feat(producer) add transaction support
new a01c0ff feat(producer) add sharding key order message support
new cedbdc9 feat(producer) add transaction message support
new 395d497 fix(producer) polish producer sample
new 1617956 Merge branch 'ctypes' into transaction_message
new 0b5270c chore(producer) hide transaction message internal state
new 5e5619f fix(sample) fix the default nameserver address
new 2f0cc8e chore(consumer) remove pull consumer implementation
new d8bc677 fix(sample)fix python3 support
new 6eed0a0 feat(test) fix the travis test failed issue when del method
invoked
new 704c210 refactor(consumer) refactor push consumer implementation
new 4fc3b68 Merge branch 'ctypes' into transaction_message
new ff1894e Merge branch 'transaction_message' of
github.com:duhenglucky/rocketmq-client-python into transaction_message
new 861525d fix(producer) fix producer error when used python3
new 3855cf8 feat(sample) add consumer sample
new 5da9c91 test(producer) add transaction producer unit test
new 117ce6c style(sample) polish sample style
new b52439b fix(test) fix transaction unit test
new d38cea0 chore(client) polish the client destory logic
new 4028ff2 chore(test) remove the delete method hack
new 9610991 chore(client) add strong response value check in callback
new b16cf01 fix(sample) fix the destroy logic in unit test
new 97338e0 chore(producer) add stronge validation in TransactionProducer
new 9a5b1cb fix(producer) fix the exc not defination error in
TransactionProducer
new 5e2064b Merge pull request #61 from duhenglucky/transaction_message
The 270 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:
README.md | 19 --
rocketmq/client.py | 262 ++++++++++++++--------------
rocketmq/exceptions.py | 16 +-
rocketmq/ffi.py | 85 +++------
samples/__init__.py | 0
rocketmq/__init__.py => samples/consumer.py | 22 ++-
samples/producer.py | 90 ++++++++++
tests/conftest.py | 17 +-
tests/test_consumer.py | 11 +-
tests/test_producer.py | 46 +++--
10 files changed, 301 insertions(+), 267 deletions(-)
create mode 100644 samples/__init__.py
copy rocketmq/__init__.py => samples/consumer.py (61%)
create mode 100644 samples/producer.py
