Реализация шины сообщений Scala от актеров?

Question

Я хочу реализовать какую-то шину сообщений в одном из моих приложений Scala. Особенности будут:

• возможности подписки на 1 .. N тип сообщений
• сообщений могут иметь полезные нагрузку
• слабосвязанность (только узлы содержат ссылку на шину)
• легких (нет полностью опущенная корпоративная очередь сообщений и т. д.)

Я планирую реализовать все узлы и сам автобус в качестве стандартных актеров Scala. Например, я хочу, чтобы определить черту Subscriber так:

trait Subscriber[M <: Message[_]] { 
    this: Actor => 
    def notify(message: M) 
} 

В идеале смешивание в этих чертах уже должно зарегистрировать подписку типа M.

Так ли это имеет смысл? Существуют ли более эффективные подходы к реализации шины сообщений?

Answer 1

Отказ от ответственности: Я PO Акки

Привет Итти,

Это уже сделано для вас в Акку, актер Kernel: www.akka.io

Docs: http://doc.akkasource.org/routing-scala

Pub/Sub: Akka Listeners Маршрутизаторы: Akka Routers Удобства: Akka Routing