Skip to content

Commit 5782949

Browse files
authored
Fix of duplication info message for unhandled message (#6532). (#6730)
1 parent 8a26155 commit 5782949

File tree

2 files changed

+2
-12
lines changed

2 files changed

+2
-12
lines changed

src/core/Akka.TestKit.Tests/TestEventListenerTests/UnhandledMessageEventFilterTests.cs

+1-2
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@
55
// </copyright>
66
//-----------------------------------------------------------------------
77

8-
using System.Text.RegularExpressions;
98
using System.Threading.Tasks;
109
using Akka.Actor;
1110
using Akka.Event;
@@ -32,7 +31,7 @@ protected override void SendRawLogEventMessage(object message)
3231
public async Task Unhandled_message_should_produce_info_message()
3332
{
3433
await EventFilter
35-
.Info(new Regex("^Unhandled message from"))
34+
.Info()
3635
.ExpectOneAsync(() => {
3736
_unhandledMessageActor.Tell("whatever");
3837
return Task.CompletedTask;

src/core/Akka.TestKit/EventFilter/TestEventListener.cs

+1-10
Original file line numberDiff line numberDiff line change
@@ -74,16 +74,7 @@ protected override bool Receive(object message)
7474
case DeadLetter letter:
7575
HandleDeadLetter(letter);
7676
break;
77-
78-
case UnhandledMessage un:
79-
{
80-
var rcp = un.Recipient;
81-
var info = new Info(rcp.Path.ToString(), rcp.GetType(), "Unhandled message from " + un.Sender + ": " + un.Message);
82-
if (!ShouldFilter(info))
83-
Print(info);
84-
break;
85-
}
86-
77+
8778
default:
8879
Print(new Debug(Context.System.Name,GetType(),message));
8980
break;

0 commit comments

Comments
 (0)