[pulsar-dotpulsar] branch master updated: Hopefully a fix for test Messages_GivenTopicWithMessages_ShouldConsumeAll that can get stuck (#145)

[bl...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

blankensteiner pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-dotpulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 9d00f6f  Hopefully a fix for test Messages_GivenTopicWithMessages_ShouldConsumeAll that can get stuck (#145)
9d00f6f is described below

commit 9d00f6f636c5b9bca343c0b89e90e80a20260d1c
Author: entvex <en...@users.noreply.github.com>
AuthorDate: Fri Mar 17 12:52:31 2023 +0100

    Hopefully a fix for test Messages_GivenTopicWithMessages_ShouldConsumeAll that can get stuck (#145)
    
    Upgraded the pulsar container image from version 2.10.3 to 2.11.0
    
    Changed the message fluent docker looks for before it continues because the log message have changed between version 2.10.3 and 2.11.0
    
    Co-authored-by: David Jensen <dj...@danskecommodities.com>
---
 tests/DotPulsar.Tests/IntegrationFixture.cs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/tests/DotPulsar.Tests/IntegrationFixture.cs b/tests/DotPulsar.Tests/IntegrationFixture.cs
index f754ca5..5879dbe 100644
--- a/tests/DotPulsar.Tests/IntegrationFixture.cs
+++ b/tests/DotPulsar.Tests/IntegrationFixture.cs
@@ -62,7 +62,7 @@ public class IntegrationFixture : IAsyncLifetime
 
         _cluster = new Builder()
             .UseContainer()
-            .UseImage("apachepulsar/pulsar:2.10.3")
+            .UseImage("apachepulsar/pulsar:2.11.0")
             .WithEnvironment(environmentVariables)
             .ExposePort(Port)
             .Command("/bin/bash -c", arguments)
@@ -85,7 +85,7 @@ public class IntegrationFixture : IAsyncLifetime
         _messageSink.OnMessage(new DiagnosticMessage("Starting container service"));
         _cluster.Start();
         _messageSink.OnMessage(new DiagnosticMessage("Container service started. Waiting for message in logs"));
-        _cluster.WaitForMessageInLogs("Successfully updated the policies on namespace public/default", int.MaxValue);
+        _cluster.WaitForMessageInLogs("[test-user] Created namespace public/default", int.MaxValue);
         _messageSink.OnMessage(new DiagnosticMessage("Got message, will now get endpoint"));
         var endpoint = _cluster.ToHostExposedEndpoint($"{Port}/tcp");
         _messageSink.OnMessage(new DiagnosticMessage($"Endpoint opened at {endpoint}"));