diff --git a/hazelcast-client/src/main/java/com/hazelcast/client/proxy/ClientReliableMessageRunner.java b/hazelcast-client/src/main/java/com/hazelcast/client/proxy/ClientReliableMessageRunner.java
index 8c68e779d2ca..4cd5775a29aa 100644
--- a/hazelcast-client/src/main/java/com/hazelcast/client/proxy/ClientReliableMessageRunner.java
+++ b/hazelcast-client/src/main/java/com/hazelcast/client/proxy/ClientReliableMessageRunner.java
@@ -16,6 +16,7 @@
 
 package com.hazelcast.client.proxy;
 
+import com.hazelcast.client.HazelcastClientNotActiveException;
 import com.hazelcast.client.HazelcastClientOfflineException;
 import com.hazelcast.core.Member;
 import com.hazelcast.logging.ILogger;
@@ -63,7 +64,13 @@ protected Member getMember(ReliableTopicMessage m) {
 
     @Override
     protected boolean handleInternalException(Throwable t) {
-        if (t instanceof HazelcastClientOfflineException) {
+        if (t instanceof HazelcastClientNotActiveException) {
+            if (logger.isFinestEnabled()) {
+                logger.finest("Terminating MessageListener " + listener + " on topic: " + topicName + ". "
+                        + " Reason: HazelcastClient is shutting down");
+            }
+            return false;
+        } else if (t instanceof HazelcastClientOfflineException) {
             if (logger.isFinestEnabled()) {
                 logger.finest("MessageListener " + listener + " on topic: " + topicName + " got exception: " + t
                         + ". Continuing from last known sequence: " + sequence);