У меня есть код Java, как показано ниже, чтобы получать сообщения из очереди, обрабатывать ее и записывать обработанное сообщение в другую очередь.
@RabbitListener(queues = "rawFusion")
@SendTo("Fusion")
public String receiverFusion(Object _message) {
String message = getMessage(_message);
return messageParser.parse(message);
}
Здесь я всегда получаю сообщения из очереди «rawFusion» и записываю их в очередь «Fusion».
То, что я хочу сделать, это писать сообщения в разные очереди в зависимости от некоторых условий. Поэтому я хотел бы выбрать параметр @SendTo (или, возможно, без использования @SendTo) после того, как получу сообщение из очереди «RawFusion».
Любая идея, как это сделать?
заранее спасибо
