От производителя я должен отправить сообщение на биржу RabbitMQ. это сообщение будет содержать определенный атрибут, например, имя очереди, основываясь на этом атрибуте, я должен динамически определить очередь для отправки этого сообщения. [очередь для привязки из exchange, чтобы отправить это конкретное сообщение].

Есть ли способ перехватить сообщение, поступающее на RabbitMQ Exchange, с помощью Spring интеграции. В настоящее время у меня есть следующий файл конфигурации Spring интеграции.

Я нене знаю, как создать bean-компонент для получения сообщений Exchange и маршрутизации сообщения в очереди smsQueue, emailQueue и т. д.

спасибо за ваши предложения и ответы.

http://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd

http://www.springframework.org/schema/integration         
http://www.springframework.org/schema/integration/spring-integration.xsd      
http://www.springframework.org/schema/context 
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/integration/amqp
http://www.springframework.org/schema/integration/amqp/spring-integration-amqp.xsd
">