Distributed solution providing messaging and queuing for streaming data