Add debug info during the login step

releated to #299

Signed-off-by: Gabriele Santomaggio <[email protected]>

Author: Gsantomaggio

RabbitMQ.Stream.Client/AvailableFeatures.cs

@@ -17,6 +17,8 @@ internal class AvailableFeatures
 
     public bool Is311OrMore { get; private set; }
 
+    public string BrokerVersion { get; private set; }
+
     private static string ExtractVersion(string fullVersion)
     {
         const string Pattern = @"(\d+\.\d+\.\d+)";
@@ -30,6 +32,7 @@ private static string ExtractVersion(string fullVersion)
     public void SetServerVersion(string brokerVersion)
     {
         var v = ExtractVersion(brokerVersion);
+        BrokerVersion = v;
         Is311OrMore = new System.Version(v) >= new System.Version("3.11.0");
     }
 

RabbitMQ.Stream.Client/Client.cs

@@ -213,7 +213,7 @@ public static async Task<Client> Create(ClientParameters parameters, ILogger log
             // exchange properties
             var peerPropertiesResponse = await client.Request<PeerPropertiesRequest, PeerPropertiesResponse>(corr =>
                 new PeerPropertiesRequest(corr, parameters.Properties)).ConfigureAwait(false);
-            logger?.LogDebug("Server properties: {@Properties}", peerPropertiesResponse);
+            logger?.LogDebug("Server properties: {@Properties}", peerPropertiesResponse.Properties);
 
             //auth
             var saslHandshakeResponse =
@@ -254,6 +254,8 @@ await client.Publish(new TuneRequest(0,
             if (peerPropertiesResponse.Properties.TryGetValue("version", out var version))
             {
                 AvailableFeaturesSingleton.Instance.SetServerVersion(version);
+                logger?.LogDebug("Extracted BrokerVersion version: {Version}",
+                    AvailableFeaturesSingleton.Instance.BrokerVersion);
                 if (AvailableFeaturesSingleton.Instance.Is311OrMore)
                 {
                     var features = await client.ExchangeVersions().ConfigureAwait(false);

docs/StreamFilter/StreamFilter/FilterConsumer.cs

@@ -18,14 +18,15 @@ public static async Task Start(string streamName)
             builder.AddFilter("RabbitMQ.Stream", LogLevel.Information);
         });
 
-        var logger = loggerFactory.CreateLogger<Consumer>();
-        var loggerMain = loggerFactory.CreateLogger<FilterConsumer>();
+        var consumerLogger = loggerFactory.CreateLogger<Consumer>();
+        var streamLogger = loggerFactory.CreateLogger<StreamSystem>();
+        var mainLogger = loggerFactory.CreateLogger<FilterConsumer>();
 
 
         var config = new StreamSystemConfig();
-        var system = await StreamSystem.Create(config).ConfigureAwait(false);
+        var system = await StreamSystem.Create(config, streamLogger).ConfigureAwait(false);
         await system.CreateStream(new StreamSpec(streamName)).ConfigureAwait(false);
-        loggerMain.LogInformation("FilterConsumer connected to RabbitMQ. StreamName {StreamName}", streamName);
+        mainLogger.LogInformation("FilterConsumer connected to RabbitMQ. StreamName {StreamName}", streamName);
 
 
         // tag::consumer-filter[]
@@ -38,19 +39,19 @@ public static async Task Start(string streamName)
             // This is mandatory for enabling the filter
             Filter = new ConsumerFilter()
             {
-                Values = new List<string>() {"Alabama"},// <1>
+                Values = new List<string>() {"Alabama"}, // <1>
                 PostFilter = message => message.ApplicationProperties["state"].Equals("Alabama"), // <2>
-                MatchUnfiltered = true 
+                MatchUnfiltered = true
             },
             MessageHandler = (_, _, _, message) =>
             {
-                logger.LogInformation("Received message with state {State} - consumed {Consumed}",
+                consumerLogger.LogInformation("Received message with state {State} - consumed {Consumed}",
                     message.ApplicationProperties["state"], ++consumedMessages);
                 return Task.CompletedTask;
             }
             // end::consumer-filter[]
-        }).ConfigureAwait(false);
-        
+        }, consumerLogger).ConfigureAwait(false);
+
         await Task.Delay(2000).ConfigureAwait(false);
         await consumer.Close().ConfigureAwait(false);
         await system.Close().ConfigureAwait(false);

docs/StreamFilter/StreamFilter/FilterProducer.cs

@@ -20,14 +20,15 @@ public static async Task Start(string streamName)
             builder.AddFilter("RabbitMQ.Stream", LogLevel.Information);
         });
 
-        var logger = loggerFactory.CreateLogger<Producer>();
-        var loggerMain = loggerFactory.CreateLogger<FilterProducer>();
+        var producerLogger = loggerFactory.CreateLogger<Producer>();
+        var streamLogger = loggerFactory.CreateLogger<StreamSystem>();
+        var mainLogger = loggerFactory.CreateLogger<FilterConsumer>();
 
 
         var config = new StreamSystemConfig();
-        var system = await StreamSystem.Create(config).ConfigureAwait(false);
+        var system = await StreamSystem.Create(config, streamLogger).ConfigureAwait(false);
         await system.CreateStream(new StreamSpec(streamName)).ConfigureAwait(false);
-        loggerMain.LogInformation("FilterProducer connected to RabbitMQ. StreamName {StreamName}", streamName);
+        mainLogger.LogInformation("FilterProducer connected to RabbitMQ. StreamName {StreamName}", streamName);
 
         var producer = await Producer.Create(new ProducerConfig(system, streamName)
         {
@@ -39,7 +40,7 @@ public static async Task Start(string streamName)
                 FilterValue = message => message.ApplicationProperties["state"].ToString(), // <1>
             }
             // end::producer-filter[]
-        }).ConfigureAwait(false);
+        },producerLogger).ConfigureAwait(false);
 
         const int ToSend = 100;
 
@@ -62,14 +63,14 @@ async Task SendTo(string state)
         // Send the first 200 messages with state "New York"
         // then we wait a bit to be sure that all the messages will go in a chunk
         await SendTo("New York").ConfigureAwait(false);
-        loggerMain.LogInformation("Sent: {MessagesSent} - filter value: {FilerValue}", ToSend * 2, "New York");
+        mainLogger.LogInformation("Sent: {MessagesSent} - filter value: {FilerValue}", ToSend * 2, "New York");
 
         // Wait a bit to be sure that all the messages will go in a chunk
         await Task.Delay(2000).ConfigureAwait(false);
 
         // Send the second 200 messages with the Alabama state
         await SendTo("Alabama").ConfigureAwait(false);
-        loggerMain.LogInformation("Sent: {MessagesSent} - filter value: {FilerValue}", ToSend * 2, "Alabama");
+        mainLogger.LogInformation("Sent: {MessagesSent} - filter value: {FilerValue}", ToSend * 2, "Alabama");
         await Task.Delay(1000).ConfigureAwait(false);
         await producer.Close().ConfigureAwait(false);
         await system.Close().ConfigureAwait(false);