simplify code

apache · Jun 28, 2021 · 0f3eea1 · 0f3eea1
1 parent d45e1a7
commit 0f3eea1
Showing 1 changed file with 1 addition and 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
@@ -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) {