You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zh...@apache.org on 2019/11/19 07:30:19 UTC
[pulsar] branch master updated (dd9e669 -> 56517d5)
This is an automated email from the ASF dual-hosted git repository.
zhaijia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from dd9e669 fix example code of java client (#5691)
add 56517d5 [PIP-38] Support batch receive in java client. (#4621)
No new revisions were added by this update.
Summary of changes:
distribution/server/licenses/LICENSE-jcip.txt | 7 +
distribution/server/src/assemble/LICENSE.bin.txt | 4 +
distribution/server/src/assemble/NOTICE.bin.txt | 3 +
pom.xml | 8 +-
.../client/api/ConsumerBatchReceiveTest.java | 296 +++++++++++++++++++++
.../pulsar/client/api/BatchReceivePolicy.java | 145 ++++++++++
.../org/apache/pulsar/client/api/Consumer.java | 75 ++++++
.../apache/pulsar/client/api/ConsumerBuilder.java | 15 ++
.../apache/pulsar/client/api/ConsumerStats.java | 10 +
.../api/{package-info.java => Messages.java} | 13 +-
pulsar-client/pom.xml | 5 +
.../apache/pulsar/client/impl/ConsumerBase.java | 267 +++++++++++++++----
.../pulsar/client/impl/ConsumerBuilderImpl.java | 9 +
.../apache/pulsar/client/impl/ConsumerImpl.java | 78 +++++-
.../pulsar/client/impl/ConsumerStatsDisabled.java | 15 ++
.../pulsar/client/impl/ConsumerStatsRecorder.java | 2 +
.../client/impl/ConsumerStatsRecorderImpl.java | 32 ++-
.../apache/pulsar/client/impl/MessagesImpl.java | 80 ++++++
.../client/impl/MultiTopicsConsumerImpl.java | 76 +++++-
.../impl/conf/ConsumerConfigurationData.java | 5 +-
.../client/impl/ConsumerBuilderImplTest.java | 14 +
.../pulsar/client/impl/ConsumerImplTest.java | 2 +
.../pulsar/PulsarConsumerSourceTests.java | 26 ++
pulsar-sql/presto-distribution/LICENSE | 4 +
site2/docs/client-libraries-java.md | 40 +++
src/check-binary-license | 2 +-
26 files changed, 1161 insertions(+), 72 deletions(-)
create mode 100644 distribution/server/licenses/LICENSE-jcip.txt
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerBatchReceiveTest.java
create mode 100644 pulsar-client-api/src/main/java/org/apache/pulsar/client/api/BatchReceivePolicy.java
copy pulsar-client-api/src/main/java/org/apache/pulsar/client/api/{package-info.java => Messages.java} (80%)
create mode 100644 pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessagesImpl.java