Skip to content

Commit 63f67dc

Browse files
authored
fix(Pulsar): Wait until the consumer becomes connected (#1467)
1 parent c053761 commit 63f67dc

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

tests/Testcontainers.Pulsar.Tests/PulsarContainerTest.cs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,9 @@ public async Task ConsumerReceivesSendMessage()
6363
_ = await consumer.OnStateChangeTo(ConsumerState.Active, TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken)
6464
.ConfigureAwait(true);
6565

66+
_ = await producer.OnStateChangeTo(ProducerState.Connected, TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken)
67+
.ConfigureAwait(true);
68+
6669
_ = await producer.Send(helloPulsar, cancellationToken: TestContext.Current.CancellationToken)
6770
.ConfigureAwait(true);
6871

0 commit comments

Comments
 (0)