made GraphStageLogic.LogSource virtual and change default `StageLog…

…ic` `LogSource` (#5360) * made `GraphStageLogic.LogSource` virtual Also, changed the default `LogSource` to be the output of the `Stage.ToString()` method. Right now all `GraphStageLogic` log sources default to just "Logic (akka://{ActorSystemName})" * changed the LogSource to be just the Stage `Type` erring on the side of less is more
akkadotnet · Nov 5, 2021 · 7732fc7 · 7732fc7
1 parent 048ea84
commit 7732fc7
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/core/Akka.API.Tests/CoreAPISpec.ApproveStreams.approved.txt b/src/core/Akka.API.Tests/CoreAPISpec.ApproveStreams.approved.txt
@@ -4640,7 +4640,7 @@ namespace Akka.Streams.Stage
         protected GraphStageLogic(Akka.Streams.Shape shape) { }
         public virtual bool KeepGoingAfterAllPortsClosed { get; }
         public Akka.Event.ILoggingAdapter Log { get; }
-        protected object LogSource { get; }
+        protected virtual object LogSource { get; }
         protected Akka.Streams.IMaterializer Materializer { get; }
         public Akka.Streams.Stage.StageActor StageActor { get; }
         [Akka.Annotations.ApiMayChangeAttribute()]

diff --git a/src/core/Akka.Streams/Stage/GraphStage.cs b/src/core/Akka.Streams/Stage/GraphStage.cs
@@ -839,6 +839,7 @@ protected GraphStageLogic(int inCount, int outCount)
         /// <param name="shape">TBD</param>
         protected GraphStageLogic(Shape shape) : this(shape.Inlets.Count(), shape.Outlets.Count())
         {
+            LogSource = Akka.Event.LogSource.Create(shape);
         }
 
         /// <summary>
@@ -879,7 +880,7 @@ public StageActor StageActor
         /// <summary>
         /// Override to customise reported log source 
         /// </summary>
-        protected object LogSource => this;
+        protected virtual object LogSource { get; }
 
         public ILoggingAdapter Log
         {