Distributed messaging and signaling

Question

I have a distributed video analysis system consisting of:

1. feature extraction: generated lots of features(20+) from each frame of the video
2. multiple detectors(in different machine): 
  * Each of them will get a subset of feature
  * Each of them needs the features from multiple frames. 
  * Eg. Detector 1 needs feature 1-5 from 3 frames to start processing; Detector 2 needs feature 2-8 from 8 frames to start processing

My question is: how to make a connection between the function extraction unit and several detectors, preferably in real time? I look at the event bus, but for just one process, would ZooKeeper in Hadoop be the best solution?

I am using Java. Any suggestions are welcome.

Answer 1

In Java, you can use the RabbitMQ message bus. There is a library with Java bindings .

RabbitMQ , , , . , . , , , .