Парни, здарова! Подскажите с многопоточностью . Работаю с RabbitMq и Cassandra. В общем consumer принимает каждую секунду около 10тыс сообщений (отдельных сообщений(json)) и после нужно их сохранить в Касандру. Решил собирать все сообщения в синхзронизированную коллекцию и каждую секунду сохранять её и после обнулять + нужно сделать ACK в раббит. Но не знаю как сделать т.к опыта в многопоточности мало. Может у кого есть куски кода или подскажите паттерн для решения. Буду очень благодарен!