Scala: Akka — несколько автобусов событий для системы акторов или события с приоритетом?

У меня есть единственная ActorSystem, у которой есть несколько подписчиков на свой eventStream. Приложение может создавать тысячи сообщений в секунду, и некоторые сообщения важнее остальных. Так что с ними надо разбираться раньше всех.

Я обнаружил, что к каждой ActorSystem подключен один поток событий, поэтому кажется, что мне нужно зарегистрировать один и тот же класс актера с двумя (или более) ActorSystems, чтобы получать важные сообщения в выделенном потоке событий.

Это предпочтительный подход или есть какие-то хитрости для этой задачи? Может быть, классификаторы тоже могут как-то подстраивать приоритеты сообщений?


person jdevelop    schedule 29.08.2012    source источник


Ответы (1)


EventStream не является структурой данных, которая содержит события, она просто направляет события подписчикам, поэтому вам следует использовать PriorityMailbox для слушателей, см. документацию по использованию приоритетных почтовых ящиков: http://doc.akka.io/docs/akka/2.0.3/scala/dispatchers.html#Почтовые ящики

person Viktor Klang    schedule 29.08.2012