ServiceBusReceiverClientIntegrationTest::peekMessage - wait after sen…

…d and before peeking
Azure · Jan 14, 2025 · 9f37782 · 9f37782
1 parent 44f4548
commit 9f37782
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...src/test/java/com/azure/messaging/servicebus/ServiceBusReceiverClientIntegrationTest.java b/...src/test/java/com/azure/messaging/servicebus/ServiceBusReceiverClientIntegrationTest.java
@@ -386,7 +386,7 @@ void receiveMessageAndComplete(MessagingEntityType entityType, boolean isSession
      */
     @MethodSource("com.azure.messaging.servicebus.IntegrationTestBase#messagingEntityWithSessions")
     @ParameterizedTest
-    void peekMessage(MessagingEntityType entityType, boolean isSessionEnabled) {
+    void peekMessage(MessagingEntityType entityType, boolean isSessionEnabled) throws InterruptedException {
         // Arrange
         setSender(entityType, TestUtils.USE_CASE_DEFAULT, isSessionEnabled);
 
@@ -397,6 +397,8 @@ void peekMessage(MessagingEntityType entityType, boolean isSessionEnabled) {
 
         setReceiver(entityType, TestUtils.USE_CASE_DEFAULT, isSessionEnabled);
 
+        TimeUnit.SECONDS.sleep(5);
+
         // Act
         ServiceBusReceivedMessage receivedMessage = receiver.peekMessage();
         logMessage(receivedMessage, receiver.getEntityPath(), "peeked messages");