Revert "modify check waitingForPingResponse with volatile (apache#12615…

…)" This reverts commit 62e2547.
michaeljmarshall · Feb 6, 2023 · f886413 · f886413
1 parent 0f72a82
commit f886413
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/PulsarHandler.java b/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/PulsarHandler.java
@@ -40,7 +40,7 @@ public abstract class PulsarHandler extends PulsarDecoder {
     protected SocketAddress remoteAddress;
     private int remoteEndpointProtocolVersion = ProtocolVersion.v0.getValue();
     private final long keepAliveIntervalSeconds;
-    private volatile boolean waitingForPingResponse = false;
+    private boolean waitingForPingResponse = false;
     private ScheduledFuture<?> keepAliveTask;
 
     public int getRemoteEndpointProtocolVersion() {