Bug 37273261 - [37107153->14.1.2.0.1] Build: Intermittent failure in NamedQueueProxyProtocolIT.shouldEnsureSimpleDequeAfterPagedQueue (14.1.2.0 cl 112682 --> ce/14.1.2.0)

[git-p4: depot-paths = "//dev/coherence-ce/release/coherence-ce-v14.1.2.0/": change = 113203]

Author: fryp

prj/test/functional/grpc-proxy-tck/src/main/java/grpc/proxy/version_1/NamedQueueProxyProtocolIT.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2000, 2024, Oracle and/or its affiliates.
+ * Copyright (c) 2000, 2025, Oracle and/or its affiliates.
  *
  * Licensed under the Universal Permissive License v 1.0 as shown at
  * https://oss.oracle.com/licenses/upl.
@@ -864,6 +864,9 @@ protected int ensureQueue(StreamObserver<ProxyRequest> channel, TestStreamObserv
         NamedQueueResponse response = unpackAny(proxyResponse, ProxyResponse::getMessage, NamedQueueResponse.class);
         int                queueId  = response.getQueueId();
 
+        // wait for the completion message
+        observer.awaitCount(responseId + 1, 1, TimeUnit.MINUTES);
+
         assertThat(queueId, is(not(0)));
         return queueId;
         }
@@ -953,7 +956,9 @@ protected <M extends Message, T extends Message> T unpackAny(M message, Function
         catch (Throwable e)
             {
             throw Exceptions.ensureRuntimeException(e,
-                    "Failed to unpack proto message: " + e.getMessage() + "\nMessage:\n" + message);
+                    "Failed to unpack proto message: " + e.getMessage()
+                            + "\nMessage:\n" + message
+                            + "\nExpected:\n" + expected);
             }
         }