Fix stream member error detection

Author: acogoluegnes

src/main/java/com/rabbitmq/client/amqp/impl/ExceptionUtils.java

@@ -132,10 +132,13 @@ static boolean unauthorizedAccess(ClientResourceRemotelyClosedException e) {
   static boolean noRunningStreamMemberOnNode(Exception e) {
     if (e instanceof AmqpException.AmqpResourceClosedException) {
       String message = e.getMessage();
-      return message != null
-          && message.contains("stream queue")
-          && message.contains("does not have a running replica on the local node")
-          && message.contains("noproc");
+      if (message == null) {
+        return false;
+      } else {
+        return (message.contains("stream queue")
+                && message.contains("does not have a running replica on the local node"))
+            || message.contains("noproc");
+      }
     } else {
       return false;
     }

src/test/java/com/rabbitmq/client/amqp/impl/ExceptionUtilsTest.java

@@ -83,6 +83,7 @@ void testNoRunningStreamMemberOnNode() {
                 new AmqpResourceClosedException(
                     "stream queue 'stream-RecoveryClusterTest_clusterRestart-a69d-db752afee52a' in vhost '/' does not have a running replica on the local node [condition = amqp:internal-error]")))
         .isTrue();
+    assertThat(noRunningStreamMemberOnNode(new AmqpResourceClosedException("noproc"))).isTrue();
     assertThat(noRunningStreamMemberOnNode(new AmqpResourceClosedException("foo"))).isFalse();
     assertThat(noRunningStreamMemberOnNode(new AmqpConnectionException("foo", null))).isFalse();
   }