Aaronontheweb on dev
Fix #4083 - Endpoint receive bu… (compare)
Aaronontheweb on dev
Convert to ImmutableHashSet for… (compare)
[Fact]
public void RequestUpdateStateSentMultipleTimes_OnlyOneResponseBack()
{
var probe = CreateTestProbe();
IActorRef putwallActor = Sys.ActorOf(PutwallActor.Props());
var guidId = Guid.NewGuid();
putwallActor.Tell(new PutwallActor.CubbyMessage.RequestUpdateState(true, guidId), probe.Ref);
var cubbyStateResponse = probe.ExpectMsg<PutwallActor.CubbyMessage.RequestUpdateState.Response>();
Assert.Equal(guidId, cubbyStateResponse.MessageId);
for (int i = 0; i < 200; i++)
{
putwallActor.Tell(new PutwallActor.CubbyMessage.RequestUpdateState(true, guidId), probe.Ref);
probe.ExpectNoMsg(TimeSpan.FromMilliseconds(1));
}
}
Hello everyone. Looking for some pointers on the right way to do the following with Akka:
Actor A needs to send a message to Actor B, however, they can’t see each other, and the only communication channel between these two actors is an Azure Blobstore that they both can read/write.
Should I be looking at implementing a custom mailbox? Custom transport? Or something else? Any recommendations welcome.
ActorCell
CurrentMessage
is still the original message that caused the throw
CurrentMessage = null
never gets to run