Skip to content
This repository has been archived by the owner on Dec 4, 2023. It is now read-only.

Commit

Permalink
Wait for all pods to be running (or terminated), before starting the …
Browse files Browse the repository at this point in the history
…persistent message test (#3054)

Signed-off-by: Vanessa <[email protected]>
  • Loading branch information
vbusch authored and famarting committed Jul 31, 2019
1 parent 4d5b872 commit 393f076
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,9 @@ public class PersistentMessagesTestBase extends TestBaseWithShared {
protected void doTestQueuePersistentMessages(Address address, int messagesBatch) throws Exception {
setAddresses(address);

// Wait for the first console pod to be terminated
TestUtils.waitUntilDeployed(kubernetes.getInfraNamespace());

int podCount = kubernetes.listPods().size();

sendDurableMessages(getSharedAddressSpace(), address, defaultCredentials, messagesBatch);
Expand Down

0 comments on commit 393f076

Please sign in to comment.