You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2022/07/20 13:35:33 UTC
[rocketmq-clients] branch cpp_dev updated (ee61403 -> de77234)
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a change to branch cpp_dev
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
from ee61403 Add an example producer, publishing timed message
add de77234 Add transactional example
No new revisions were added by this update.
Summary of changes:
cpp/README.md | 17 ++-
cpp/examples/BUILD.bazel | 48 ++-------
cpp/examples/ExampleFifoPushConsumer.cpp | 67 ------------
cpp/examples/ExampleProducer.cpp | 28 +++--
...ncProducer.cpp => ExampleProducerWithAsync.cpp} | 9 +-
...ucer.cpp => ExampleProducerWithFifoMessage.cpp} | 12 ++-
...=> ExampleProducerWithTransactionalMessage.cpp} | 39 +++----
cpp/examples/ExampleTransactionProducer.cpp | 52 ---------
cpp/examples/SqlConsumer.cpp | 62 -----------
cpp/examples/SqlProducer.cpp | 116 ---------------------
cpp/include/rocketmq/Message.h | 1 +
cpp/include/rocketmq/Producer.h | 5 +
cpp/include/rocketmq/SendReceipt.h | 2 +
cpp/include/rocketmq/Transaction.h | 10 --
cpp/source/base/ThreadPoolImpl.cpp | 2 +-
cpp/source/client/ClientManagerImpl.cpp | 15 ++-
cpp/source/client/TelemetryBidiReactor.cpp | 5 +-
cpp/source/rocketmq/Producer.cpp | 9 ++
cpp/source/rocketmq/ProducerImpl.cpp | 79 +++++++-------
cpp/source/rocketmq/TransactionImpl.cpp | 25 +++--
cpp/source/rocketmq/include/ProducerImpl.h | 17 +--
cpp/source/rocketmq/include/TransactionImpl.h | 47 +++------
cpp/source/scheduler/SchedulerImpl.cpp | 2 +-
23 files changed, 199 insertions(+), 470 deletions(-)
delete mode 100644 cpp/examples/ExampleFifoPushConsumer.cpp
rename cpp/examples/{ExampleAsyncProducer.cpp => ExampleProducerWithAsync.cpp} (92%)
rename cpp/examples/{ExampleFifoProducer.cpp => ExampleProducerWithFifoMessage.cpp} (90%)
copy cpp/examples/{ExampleProducerWithTimedMessage.cpp => ExampleProducerWithTransactionalMessage.cpp} (76%)
delete mode 100644 cpp/examples/ExampleTransactionProducer.cpp
delete mode 100644 cpp/examples/SqlConsumer.cpp
delete mode 100644 cpp/examples/SqlProducer.cpp