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

[blankensteiner]

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 <ent...@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 <d...@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}"));