This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a change to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar-client-cpp.git
from 6fdcf21 Fixed validation of cluster/namespace names containing legal
non-alpha characters (#52)
new a671640 Use parametrized job to build packages (#36)
new d7ccefd Updated Github actions versions to avoid deprecations (#49)
new 99d5dc1 [feat] Consumer support batch receive messages. (#21)
new 361a621 [fix] Fix memory leak caused by incorrect close and
destruction (#54)
new b617a7f [flaky-test] Fix very flaky tests for TEST_P (#59)
new f70aa89 Fixed the release artifacts package file name (#113)
The 6 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:
.github/workflows/ci-build-binary-artifacts.yaml | 217 ++------------
.github/workflows/ci-pr-validation.yaml | 99 ++----
include/pulsar/BatchReceivePolicy.h | 90 ++++++
include/pulsar/Consumer.h | 25 ++
include/pulsar/ConsumerConfiguration.h | 18 ++
lib/BatchReceivePolicy.cc | 57 ++++
.../crc32c_sw.h => BatchReceivePolicyImpl.h} | 8 +-
lib/ClientConnection.h | 2 +-
lib/ClientImpl.cc | 89 +++---
lib/ClientImpl.h | 18 +-
lib/ConnectionPool.h | 4 +-
lib/Consumer.cc | 18 ++
lib/ConsumerConfiguration.cc | 9 +
lib/ConsumerConfigurationImpl.h | 1 +
lib/ConsumerImpl.cc | 283 +++++++++---------
lib/ConsumerImpl.h | 20 +-
lib/ConsumerImplBase.cc | 141 +++++++++
lib/ConsumerImplBase.h | 45 ++-
lib/HandlerBase.cc | 24 +-
lib/HandlerBase.h | 21 +-
lib/MessagesImpl.cc | 58 ++++
.../pulsar/MessageBatch.h => lib/MessagesImpl.h | 37 ++-
lib/MultiTopicsConsumerImpl.cc | 331 +++++++++++++++------
lib/MultiTopicsConsumerImpl.h | 33 +-
lib/PartitionedProducerImpl.cc | 83 ++++--
lib/PartitionedProducerImpl.h | 5 +-
lib/PatternMultiTopicsConsumerImpl.cc | 19 +-
lib/PatternMultiTopicsConsumerImpl.h | 1 +
lib/PeriodicTask.cc | 5 +-
lib/PeriodicTask.h | 2 +-
lib/ProducerImpl.cc | 90 +++---
lib/ProducerImpl.h | 5 +-
lib/SynchronizedHashMap.h | 18 +-
tests/BasicEndToEndTest.cc | 181 +++++++++++
...odecSnappyTest.cc => BatchReceivePolicyTest.cc} | 30 +-
tests/ClientTest.cc | 28 +-
tests/ConsumerConfigurationTest.cc | 8 +
tests/MessagesImplTest.cc | 61 ++++
tests/ProducerTest.cc | 6 +-
tests/PulsarFriend.h | 35 ++-
tests/ShutdownTest.cc | 129 ++++++++
tests/WaitUtils.h | 43 ---
42 files changed, 1611 insertions(+), 786 deletions(-)
create mode 100644 include/pulsar/BatchReceivePolicy.h
create mode 100644 lib/BatchReceivePolicy.cc
copy lib/{checksum/crc32c_sw.h => BatchReceivePolicyImpl.h} (89%)
create mode 100644 lib/ConsumerImplBase.cc
create mode 100644 lib/MessagesImpl.cc
copy include/pulsar/MessageBatch.h => lib/MessagesImpl.h (61%)
copy tests/{CompressionCodecSnappyTest.cc => BatchReceivePolicyTest.cc} (55%)
create mode 100644 tests/MessagesImplTest.cc
create mode 100644 tests/ShutdownTest.cc
delete mode 100644 tests/WaitUtils.h
