ConcurrentQueueMailbox
can support bounded, unbounded message queues - and those message queues can also have deque semantics for stashing
akka {
stdout-loglevel = ERROR
loglevel = DEBUG
actor {
debug {
receive = on
autoreceive = on
lifecycle = on
event-stream = on
unhandled = on
}
}
}
replay-mailbox {
mailbox-type: "TrafficSimulator.PlaybackApp.Actors.ReplayMailbox,TrafficSimulator.PlaybackApp"
}
_replyAgents =
Context.ActorOf(
Props.Create(() => new ReplayActor(new ReplaySettings() {Host = _httpAuthority}, Self))
.WithRouter(new RoundRobinPool(2, new DefaultResizer(2, 15))).WithMailbox("replay-mailbox"));