Please, tell me if any of my assumptions are wrong:

  1.  I have a data analysis streaming project using AMQ as temporary store. I 
know, most projects use Kafka, but in our company, AMQ is standard tool for 
everything “inter services communication”, and I love it 😊 .
  2.  One service will send a Json message with data to an address, and then 
several queues receive a copy of that message (it’s the purpose of multicast, 
right?).
  3.  Each queue will have an aggregator service as consumer, where each 
service receiving the messages generate one (of dozens) of real time indicators 
(It’s a kind more complex than that).
  4.  If one consumer is stopped, the respective queue will continue to receive 
the messages until the service is restarted.

Thanks in advance,

ER.

Reply via email to