Реализация длительного опроса в scala и play 2.0 с помощью akka

Я реализую длительный опрос в Play 2.0 в потенциально распределенной среде. Насколько я понимаю, когда Play получает запрос, он должен приостановить ожидание уведомления об обновлении, а затем перейти к базе данных, чтобы получить новые данные и повторить. Я начал смотреть на пример чата, который предлагает Play 2.0, но он находится в веб-сокете. Кроме того, не похоже, что его можно распространять. Поэтому я подумал, что буду использовать шину событий Akka. Я взял реализацию потока событий и воспроизвел свою собственную с помощью LookupClassification. Однако я не понимаю, как я получу ответное сообщение (или, если уж на то пошло, какой должен быть подписчик вместо ActorRef)?

Реализация EventStream: https://github.com/akka/akka/blob/master/akka-actor/src/main/scala/akka/event/EventStream.scala

13
задан Mortimer 25 May 2012 в 17:24
поделиться