Add the "noproc" case to detect the no-local-stream-member error

Author: acogoluegnes

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

@@ -307,11 +307,7 @@ void recoverAfterConnectionFailure() {
                     this.nativeHandler,
                     this.nativeCloseHandler),
             e -> {
-              boolean shouldRetry =
-                  e instanceof AmqpException.AmqpResourceClosedException
-                      && e.getMessage().contains("stream queue")
-                      && e.getMessage()
-                          .contains("does not have a running replica on the local node");
+              boolean shouldRetry = ExceptionUtils.noRunningStreamMemberOnNode(e);
               LOGGER.debug("Retrying receiver creation on consumer recovery: {}", shouldRetry);
               return shouldRetry;
             },

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

@@ -129,12 +129,13 @@ static boolean unauthorizedAccess(ClientResourceRemotelyClosedException e) {
     return isUnauthorizedAccess(e.getErrorCondition());
   }
 
-  static boolean noRunningStreamMemberOnNode(AmqpException 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("does not have a running replica on the local node")
+          && message.contains("noproc");
     } else {
       return false;
     }