You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by si...@apache.org on 2020/04/06 18:17:10 UTC

[pulsar] branch master updated (41e3906 -> 30e762e)

This is an automated email from the ASF dual-hosted git repository.

sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.


    from 41e3906  Remove PULSAR_PREFIX for k8s yaml and helm values file (#6671)
     add 30e762e  Support Consumers Set Custom Retry Delay (#6449)

No new revisions were added by this update.

Summary of changes:
 ...eadLetterTopicTest.java => RetryTopicTest.java} |  63 +++------
 .../org/apache/pulsar/client/api/Consumer.java     | 103 +++++++++++++++
 .../apache/pulsar/client/api/ConsumerBuilder.java  |  10 ++
 .../apache/pulsar/client/api/DeadLetterPolicy.java |   7 +-
 .../apache/pulsar/client/impl/ConsumerBase.java    |  75 +++++++++++
 .../pulsar/client/impl/ConsumerBuilderImpl.java    |  30 ++++-
 .../apache/pulsar/client/impl/ConsumerImpl.java    | 141 ++++++++++++++++++++-
 .../client/impl/MultiTopicsConsumerImpl.java       |  28 ++++
 .../impl/conf/ConsumerConfigurationData.java       |   2 +
 .../pulsar/client/util/RetryMessageUtil.java       |  29 ++---
 .../pulsar/client/tutorial/SampleConsumer.java     |   9 +-
 .../pulsar/PulsarConsumerSourceTests.java          |  32 +++++
 12 files changed, 463 insertions(+), 66 deletions(-)
 copy pulsar-broker/src/test/java/org/apache/pulsar/client/api/{DeadLetterTopicTest.java => RetryTopicTest.java} (80%)
 copy pulsar-functions/proto/src/main/proto/Request.proto => pulsar-client/src/main/java/org/apache/pulsar/client/util/RetryMessageUtil.java (58%)