From 0f3eea1af13111cdcf92ae983b389ddf130f145b Mon Sep 17 00:00:00 2001
From: aloyszhang <lofterzhang@gmail.com>
Date: Mon, 28 Jun 2021 18:52:26 +0800
Subject: [PATCH] simplify code

---
 .../main/java/org/apache/pulsar/client/impl/MessageImpl.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java
index 695e849bbc7b70..cf253cf5bbc863 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java
@@ -281,12 +281,11 @@ public static long getEntryTimestamp( ByteBuf headersAndPayloadWithBrokerEntryMe
         MessageImpl<byte[]> msg = (MessageImpl<byte[]>) RECYCLER.get();
         try {
             Commands.parseMessageMetadata(headersAndPayloadWithBrokerEntryMetadata, msg.msgMetadata);
-            entryTimestamp  = msg.getPublishTime();
+            return msg.getPublishTime();
         } finally {
             // make sure msg can be recycled
             msg.recycle();
         }
-        return entryTimestamp;
     }
 
     public static boolean isEntryExpired(int messageTTLInSeconds, long entryTimestamp) {