У меня есть RabbitListener, который выглядит так: @RabbitListener public class ProductListener { @Queue(value = "product", executor = "product-listener") public void receive(MyType message) { // process...