История изменений

Я знаю и использую zmq, но тут у меня будут десятки тысяч сообщений и тысячи воркеров + выч. кластер (в котором ещё и машинки могут быть разные + добавлять при необходимости).

Было бы там с десяток воркеров и пиковая загрузка очередей небольшой - без проблем бы написал на zmq, написал миксер и радовался жизни. А тут хочется, чтобы всё это как-то сейвилось и баги за меня половили бы уже.

Если придётся, то напишу. Но сначала хочу посмотреть на готовые решения, может быть что-то мне подойдёт и я не буду тратить время на создание велосипеда.

P.S. Поясню, если воркеры с потоком сообщений не справляются, то сообщения должны посейвится на диск, но не потеряться. Отследим, что кол-во сообщений растёт и добавим воркеров. Писать слой гарантировая доставки сообщений не хочется вот и всё. Поэтому и ищется, что-то более высокоуровневое чем zmq.

Я знаю и использую zmq, но тут у меня будут десятки тысяч сообщений и тысячи воркеров + выч. кластер (в котором ещё и машинки могут быть разные + добавлять при необходимости).

Было бы там с десяток воркеров и пиковая загрузка очередей небольшой - без проблем бы написал на zmq, написал миксер и радовался жизни. А тут хочется, чтобы всё это как-то сейвилось и баги за меня половили бы уже.

Если придётся, то напишу. Но сначала хочу посмотреть на готовые решения, может быть что-то мне подойдёт и я не буду тратить время на создание велосипеда.