This is an automated email from the ASF dual-hosted git repository.
xyz pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-client-cpp.git
from 3e5c9c7 [feat] Reader support readeNextAsync interface. (#176)
add 9ed6a45 [feat] Support Dead Letter Topic. (#139)
No new revisions were added by this update.
Summary of changes:
include/pulsar/ConsumerConfiguration.h | 39 ++
...{ConsumerEventListener.h => DeadLetterPolicy.h} | 52 ++-
include/pulsar/DeadLetterPolicyBuilder.h | 94 +++++
include/pulsar/ProducerConfiguration.h | 7 +-
lib/Commands.cc | 6 +-
lib/Commands.h | 3 +-
lib/ConsumerConfiguration.cc | 6 +
lib/ConsumerConfigurationImpl.h | 1 +
lib/ConsumerImpl.cc | 174 ++++++++-
lib/ConsumerImpl.h | 14 +
lib/DeadLetterPolicyBuilder.cc | 55 +++
lib/{MessagesImpl.h => DeadLetterPolicyImpl.cc} | 33 +-
...hReceivePolicyImpl.h => DeadLetterPolicyImpl.h} | 11 +-
lib/MessageIdImpl.h | 25 ++
lib/MultiTopicsConsumerImpl.cc | 18 +-
lib/NegativeAcksTracker.cc | 2 +-
lib/ProducerConfigurationImpl.h | 1 +
lib/ProducerImpl.cc | 10 +-
tests/ConsumerConfigurationTest.cc | 16 +
tests/DeadLetterPolicyTest.cc | 45 +++
tests/DeadLetterQueueTest.cc | 392 +++++++++++++++++++++
tests/PulsarFriend.h | 6 +
22 files changed, 957 insertions(+), 53 deletions(-)
copy include/pulsar/{ConsumerEventListener.h => DeadLetterPolicy.h} (51%)
create mode 100644 include/pulsar/DeadLetterPolicyBuilder.h
create mode 100644 lib/DeadLetterPolicyBuilder.cc
copy lib/{MessagesImpl.h => DeadLetterPolicyImpl.cc} (59%)
copy lib/{BatchReceivePolicyImpl.h => DeadLetterPolicyImpl.h} (83%)
create mode 100644 tests/DeadLetterPolicyTest.cc
create mode 100644 tests/DeadLetterQueueTest.cc
