В настоящее время, насколько я понимаю эти вопросы (здесь и здесь), в AWS Messaging для Spring Boot необходимо установить имя очереди или URL-адрес очереди в определении аннотации @SqsListener как статическую строку, которую Spring может прочитать. запускать. Вы не можете сделать его переменной или списком очередей, чтобы вы могли определить один метод и сделать этот метод обработчиком для всех этих очередей SQS.
В моем приложении более 40 очередей. Я хотел бы взять некоторые из этих очередей, поместить их в список и передать его в аннотацию @SqsListener, чтобы у меня был один метод для этих X очередей, и поместить другой набор очередей Y в аннотация другого метода. Но, похоже, я не смогу этого сделать. Это правда? Есть ли другой способ сделать это?
Мне начинает не нравиться реализация пакета maven Spring-cloud-aws-messaging с Аннотация @SqsListener для метода, который «прослушивает» определенную очередь и вызывает этот метод при поступлении нового сообщения. Не в последнюю очередь потому, что это заставляет меня использовать версию 1.0 пакета AWS Java SQS SDK вместо возможности использовать версию 2.0. Я бы предпочел как-нибудь провести опрос самостоятельно весной, но не знаю, как это сделать. Как я могу опросить список очередей SQS в Spring Boot? Мне бы хотелось, чтобы я мог просто настроить его на длинный опрос примерно на 20 секунд (максимум согласно AWS), и если он находит сообщение, он возвращает его и начинает следующий опрос. Возможно ли это?
Подробнее здесь: https://stackoverflow.com/questions/601 ... hod-implem
Есть ли способ динамически назначать очереди SQS реализации метода @SqsListener вместо того, чтобы они были статическими ⇐ JAVA
-
- Похожие темы
- Ответы
- Просмотры
- Последнее сообщение
-
-
Невозможно получить атрибуты очереди AWS SQS с помощью Java и TestContainers.
Anonymous » » в форуме JAVA - 0 Ответы
- 16 Просмотры
-
Последнее сообщение Anonymous
-