I am seeing a problem in using the DataProvider class.
I have registered a listener (Reactor) to my MentionsProvider as
follows:
listenTo(mentionsProvider);
reactions += {
case evt: NewTwitterDataEvent => {
val newTweets = evt.data.asInstanceOf[List[TwitterStatus]]
log.info("Tweets Arrived: " + newTweets.length)
processStatuses(newTweets)
}
}
This works sometimes just fine. However, sometimes after a couple of
NewTwitterDataEvents are sent this reaction is lost on the
DataProvider and doesn't get called anymore.
Has anybody seen similar problems with the DataProvider or with the
Publisher/Reactor usage in scala ?
Thanks,
James