Skip to content

Commit

Permalink
Bug 37107153 - Build: Intermittent failure in NamedQueueProxyProtocol…
Browse files Browse the repository at this point in the history
…IT.shouldEnsureSimpleDequeAfterPagedQueue

(merge main -> ce/main 112352)

[git-p4: depot-paths = "//dev/coherence-ce/main/": change = 112353]
  • Loading branch information
thegridman committed Nov 12, 2024
1 parent 048772e commit fa2953e
Showing 1 changed file with 6 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
}
Expand Down Expand Up @@ -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);
}
}

Expand Down

0 comments on commit fa2953e

Please sign in to comment.