4
Что такое redis.publish();
способ сделать в следующем модуле.Что делает метод redis.publish() 'Redis?
redis.publish("WordCountTopology", exclamatedWord.toString() + "|" + Long.toString(count));
public void execute(Tuple tuple)
{
String word = tuple.getString(0);
StringBuilder exclamatedWord = new StringBuilder();
exclamatedWord.append(word).append("!!!");
_collector.emit(tuple, new Values(exclamatedWord.toString()));
long count = 30;
redis.publish("WordCountTopology", exclamatedWord.toString() + "|" + Long.toString(count));
}
хорошо читать: [здесь] (http://robots.thoughtbot.com/redis-pub-sub-how-does-it-work) –