Skip to content

Commit babb1dc

Browse files
committed
Bug 37107153 - Build: Intermittent failure in NamedQueueProxyProtocolIT.shouldEnsureSimpleDequeAfterPagedQueue
(merge ce/main -> ce/24.09 112353) [git-p4: depot-paths = "//dev/coherence-ce/release/coherence-ce-v24.09/": change = 112354]
1 parent d03f244 commit babb1dc

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

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

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -864,6 +864,9 @@ protected int ensureQueue(StreamObserver<ProxyRequest> channel, TestStreamObserv
864864
NamedQueueResponse response = unpackAny(proxyResponse, ProxyResponse::getMessage, NamedQueueResponse.class);
865865
int queueId = response.getQueueId();
866866

867+
// wait for the completion message
868+
observer.awaitCount(responseId + 1, 1, TimeUnit.MINUTES);
869+
867870
assertThat(queueId, is(not(0)));
868871
return queueId;
869872
}
@@ -953,7 +956,9 @@ protected <M extends Message, T extends Message> T unpackAny(M message, Function
953956
catch (Throwable e)
954957
{
955958
throw Exceptions.ensureRuntimeException(e,
956-
"Failed to unpack proto message: " + e.getMessage() + "\nMessage:\n" + message);
959+
"Failed to unpack proto message: " + e.getMessage()
960+
+ "\nMessage:\n" + message
961+
+ "\nExpected:\n" + expected);
957962
}
958963
}
959964

0 commit comments

Comments
 (0)