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/21 02:18:47 UTC

[pulsar] 15/16: Fix MessagePayloadContextImpl not recycled (#13233)

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

penghui pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit d9da67710a4cc623cc080244ca91fceef3ea426a
Author: Yunze Xu <xy...@163.com>
AuthorDate: Sat Dec 11 00:09:19 2021 +0800

    Fix MessagePayloadContextImpl not recycled (#13233)
    
    (cherry picked from commit 0ce155ea3420306a5f9c9d3ff22f4c0d92e5ec71)
---
 .../java/org/apache/pulsar/client/impl/MessagePayloadContextImpl.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessagePayloadContextImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessagePayloadContextImpl.java
index aa6cab8..f219003 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessagePayloadContextImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessagePayloadContextImpl.java
@@ -88,6 +88,7 @@ public class MessagePayloadContextImpl implements MessagePayloadContext {
             ackBitSet.recycle();
             ackBitSet = null;
         }
+        recyclerHandle.recycle(this);
     }
 
     @Override