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);