diff --git a/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/TargetHandler.java b/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/TargetHandler.java
index 1480e49f44..76f5694006 100644
--- a/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/TargetHandler.java
+++ b/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/TargetHandler.java
@@ -624,7 +624,8 @@ public void inputReady(NHttpClientConnection conn, ContentDecoder decoder) {
                 int responseRead = -1;
                 boolean interceptionEnabled = false;
                 Boolean[] interceptorResults = new Boolean[noOfInterceptors];
-                if (interceptStream) {
+                if (conn.getContext().getAttribute(PassThroughConstants.RESPONSE_MESSAGE_CONTEXT) != null
+                        && interceptStream) {
                     int index = 0;
                     for (StreamInterceptor interceptor : streamInterceptors) {
                         interceptorResults[index] = interceptor.interceptTargetResponse(