Контекст : я реализую приложение в CQRS и пытаюсь оптимизировать обработку команд (в основном 1 поток по совокупному идентификатору)... Проблема : я хотел бы иметь первый поток, который получает все команды и отправляет их по их совокупному...