message broker for JSON data streams