diff --git a/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/Pipe.java b/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/Pipe.java
index a13403bd16..d8d3804b59 100644
--- a/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/Pipe.java
+++ b/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/Pipe.java
@@ -96,9 +96,9 @@ public boolean isProducerCompleted() {
 
     private BaseConfiguration baseConfig;
 
-    private boolean serializationComplete = false;
+    private volatile boolean serializationComplete = false;
 
-    private boolean rawSerializationComplete = false;
+    private volatile boolean rawSerializationComplete = false;
 
     private boolean hasHttpProducer = true;