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

Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/12/29 02:24:51 UTC

[pulsar] branch master updated (1ea4ad8 -> 862e120)

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

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


    from 1ea4ad8  [Pulsar SQL] support protobuf/timestamp (#13287)
     add 862e120  [PIP 107][Client] Introduce chunk message ID (#12403)

No new revisions were added by this update.

Summary of changes:
 .../pulsar/client/impl/MessageChunkingTest.java    | 58 ++++++++++++++
 .../pulsar/client/impl/ChunkMessageIdImpl.java     | 75 ++++++++++++++++++
 .../apache/pulsar/client/impl/ConsumerImpl.java    | 32 +++++---
 .../apache/pulsar/client/impl/MessageIdImpl.java   | 27 +++++--
 .../org/apache/pulsar/client/impl/MessageImpl.java |  2 +-
 .../apache/pulsar/client/impl/ProducerImpl.java    | 68 ++++++++++++++++-
 .../pulsar/client/impl/ChunkMessageIdImplTest.java | 88 ++++++++++++++++++++++
 .../pulsar/client/impl/ProducerImplTest.java       | 49 ++++++++++++
 pulsar-common/src/main/proto/PulsarApi.proto       |  3 +
 9 files changed, 383 insertions(+), 19 deletions(-)
 create mode 100644 pulsar-client/src/main/java/org/apache/pulsar/client/impl/ChunkMessageIdImpl.java
 create mode 100644 pulsar-client/src/test/java/org/apache/pulsar/client/impl/ChunkMessageIdImplTest.java
 create mode 100644 pulsar-client/src/test/java/org/apache/pulsar/client/impl/ProducerImplTest.java