checkstyle

apache · Dec 19, 2024 · 9ec0f2c · 9ec0f2c
1 parent 603e559
commit 9ec0f2c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/GeoReplicationProducerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/GeoReplicationProducerImpl.java
@@ -118,7 +118,7 @@ private void ackReceivedReplicatedMsg(ClientCnx cnx, OpSendMsg op, long sourceLI
         }
 
         // Case-2, which is expected.
-        if (pendingLId!= null && pendingEId != null && sourceLId == pendingLId && sourceEId == pendingEId) {
+        if (pendingLId != null && pendingEId != null && sourceLId == pendingLId && sourceEId == pendingEId) {
             // Case-3, which is expected.
             // Q: After a reconnect, maybe we have lost the response of Send-Receipt, then how can we remove
             //    pending messages from the queue?