Skip to content

Instantly share code, notes, and snippets.

@adpande
Created September 21, 2013 14:40
Show Gist options
  • Save adpande/6651259 to your computer and use it in GitHub Desktop.
Save adpande/6651259 to your computer and use it in GitHub Desktop.
package actors
import akka.actor.Actor
import akka.actor.Props
import akka.event.Logging
import indexing.{TopicIndexManager, TopicIndex}
/**
*
* User: apande
* Date: 10/7/13
* Time: 11:30 PM
*
*/
class IndexActor extends Actor {
val log = Logging(context.system, this)
def receive = {
case topic:TopicIndex => {
TopicIndexManager.index(topic)
log.debug("Topic Indexed!")
}
case _ => log.info("received unknown message")
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment