2016-08-21 5 views
1

У меня есть RoundRobinPool, для которого я хочу использовать OneForOneStategy, чтобы когда ребенок выбрасывал только тот ребенок, который перезагружается. Я создаю маршрутизатор, как это:akka.net только перезапускает один маршрут в пуле

var strat = new OneForOneStrategy(1, TimeSpan.FromSeconds(5), e => Directive.Restart); 

var props = Props.Create<ThrowAlwaysActor>() 
         .WithRouter(new RoundRobinPool(2)) 
         .WithSupervisorStrategy(strat); 

var router = system.ActorOf(props, "myrouter"); 
router.Tell("1"); 

выход:

akka://loadSystem/user/myrouter/$b PRERESTART <-- pool init 
akka://loadSystem/user/myrouter/$a PRERESTART <-- pool init 
akka://loadSystem/user/myrouter/$a OnReceive() 
[ERROR][8/21/2016 8:21:02 AM][Thread 0004][akka://loadSystem/user/myrouter] The method or operation is not implemented. 
akka://loadSystem/user/myrouter/$a PRERESTART <-- the actor that threw is being restarted 
akka://loadSystem/user/myrouter/$b PRERESTART <-- this actor should not be restarted 

Как настроить пул RoundRobin только перезапустить routee, что выбросил исключение и избежать весь бассейн получать перезапущен.

ответ

1

Выдерживает стратегию конструктору бассейна вместо беглого реквизита строитель:

var routerStrat = new OneForOneStrategy(-1, TimeSpan.FromSeconds(5), e => Directive.Restart); 

var props = Props.Create<ThrowAlwaysActor>() 
         .WithRouter(new RoundRobinPool(2, resizer, routerStrat, null));