From 073ab860fe8ac4ab3d567a0cb3a3fe2ddeae8308 Mon Sep 17 00:00:00 2001 From: lordchen1020 <1572139390@qq.com> Date: Sun, 24 Oct 2021 12:49:33 +0800 Subject: [PATCH] remove unused isTxnMessage --- .../main/java/org/apache/pulsar/client/impl/ConsumerImpl.java | 4 ---- 1 file changed, 4 deletions(-) diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java index b29d6c73deff6..c58231516d94e 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java @@ -1239,10 +1239,6 @@ private void tryTriggerListener() { } } - private boolean isTxnMessage(MessageMetadata messageMetadata) { - return messageMetadata.hasTxnidMostBits() && messageMetadata.hasTxnidLeastBits(); - } - private ByteBuf processMessageChunk(ByteBuf compressedPayload, MessageMetadata msgMetadata, MessageIdImpl msgId, MessageIdData messageId, ClientCnx cnx) {