From 9b5f64e5d6c93f800e0286f700eebde646dd37f4 Mon Sep 17 00:00:00 2001
From: Soby Chacko <chackos@vmware.com>
Date: Wed, 15 Feb 2023 13:01:53 -0500
Subject: [PATCH] Reader test improvements in latestMessageId test

- Enusre that the container is started
- Increase the latch wait timeout
---
 .../reader/DefaultPulsarReaderListenerContainerTests.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/spring-pulsar/src/test/java/org/springframework/pulsar/reader/DefaultPulsarReaderListenerContainerTests.java b/spring-pulsar/src/test/java/org/springframework/pulsar/reader/DefaultPulsarReaderListenerContainerTests.java
index d75db74f..d57f6767 100644
--- a/spring-pulsar/src/test/java/org/springframework/pulsar/reader/DefaultPulsarReaderListenerContainerTests.java
+++ b/spring-pulsar/src/test/java/org/springframework/pulsar/reader/DefaultPulsarReaderListenerContainerTests.java
@@ -154,11 +154,11 @@ public class DefaultPulsarReaderListenerContainerTests implements PulsarTestCont
 				pulsarTemplate.sendAsync("This message should not be received by the reader");
 			}
 			container.start();
-
+			assertThat(container.isRunning()).isTrue();
 			pulsarTemplate.sendAsync("This message should be received by the reader");
 			pulsarTemplate.sendAsync("This message should be received by the reader");
 
-			assertThat(latch.await(10, TimeUnit.SECONDS)).isTrue();
+			assertThat(latch.await(30, TimeUnit.SECONDS)).isTrue();
 		}
 		finally {
 			safeStopContainer(container);