Вопросы по теме 'spring-rabbit'
Уведомление об отключении/повторном подключении брокера AMQP с помощью Spring-AMQP/RabbitMQ
Одна из приятных особенностей Spring-AMQP заключается в том, что он, по-видимому, реализует необходимую логику для повторного подключения приложения Spring к брокеру сообщений, когда брокер выходит из строя и снова включается.
То, что я ищу, - это...
2887 просмотров
schedule
27.12.2022
Отправка файлов через RabbitMQ
Стоит ли отправлять файлы размером около 1 Мб через RabbitMQ? Я хочу отправить сообщение в формате json с двоичными полями, соответствующими файлам.
И как это правильно сделать с помощью spring-amqp? Просто опубликовав объект со следующим...
7213 просмотров
schedule
09.02.2023
spring-rabbit не останавливает потоки, он запускается, когда я выключаю Tomcat
Когда я выключаю tomcat, я получаю эти сообщения в журнале, и JVM не выпускает процесс:
Jan 16, 2015 4:20:25 PM org.apache.catalina.loader.WebappClassLoader clearReferencesThreads
SEVERE: The web application [/myproject] appears to have started a...
805 просмотров
schedule
07.08.2023
Как сбалансировать запросы паблишеров с RabbitMQ?
Предположим, у вас есть несколько производителей и один потребитель, который хочет получать постоянные сообщения от всех доступных издателей.
Производители работают с разной скоростью. Допустим, система A производит 10 запросов в секунду, а...
312 просмотров
schedule
02.05.2023
запросить сообщение в rabbitmq с помощью Spring ampq
Я новичок в rabbitmq и пробую следующий сценарий
-> производитель отправляет сообщение -> потребитель получает сообщение - Выполнить мою собственную логику
если логика не работает - запросите
-> повторно поставить сообщение в очередь,...
3656 просмотров
schedule
27.07.2023
Отправляйте и получайте на обмене фан-аутом RabbitMQ через Spring
Я работаю с RabbitMQ, и меня смущает использование разветвленного обмена и convertSendAndReceive (или sendAndReceive ) метода класса RabbitTemplate .
Например, у меня есть 2 потребителя для долговременных очередей QUEUE-01 и QUEUE-02, которые...
1072 просмотров
schedule
07.04.2023
Весна: @Autowired не работает
Это не повторяющийся вопрос. Ответьте на этот вопрос. Я использую Spring 4.0.2. Это веб-приложение, в котором я использую RabbitMQ Server для одновременной обработки нескольких заданий. Я использовал объект @Autowired в службах контроллера и...
1577 просмотров
schedule
11.04.2022
Сервер Tomcat зависает во время запуска при использовании Spring Rabbit
Я использую Spring Rabbit 1.5.1 в одном из своих проектов, и у меня есть некоторый пользовательский код, который создает объекты контейнера прослушивателя на лету во время запуска (не в конфигурации, а программно через bean ). Но сервер, кажется,...
570 просмотров
schedule
01.04.2023
Невозможно подключить Spring AMQP / Rabbit MQ: org.springframework.amqp.AmqpConnectException: java.net.ConnectException: в соединении отказано: подключение
Я новичок в Spring AMQP / Rabbit MQ.
Я использую Spring AMQP / Rabbit MQ в своем проекте. Я столкнулся со следующей ошибкой после запуска tomcat:
org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer - исключение,...
41344 просмотров
schedule
15.08.2022
Spring Amqp имеет NoClassDefFoundError в классе springframework RetryCallback
Я работаю над распределенным веб-проектом и хочу использовать Spring amqp, используя в нем RabbitMq. Я использую SpringFramework версии 4.1.6 в своем проекте. Для этого я добавил в файл pom.xml следующие зависимости.
<dependency>...
11475 просмотров
schedule
06.11.2022
Динамическая аннотация SendTo
У меня есть код Java, как показано ниже, чтобы получать сообщения из очереди, обрабатывать ее и записывать обработанное сообщение в другую очередь.
@RabbitListener(queues = "rawFusion")
@SendTo("Fusion")
public String...
1789 просмотров
schedule
07.06.2022
Java/Spring - отправить сообщение RabbitMQ изнутри потребителя
Законно и безопасно ли отправлять сообщение в другую очередь от потребителя текущей очереди?
public void onMessage(){
//save to db
Order o=myservice.create(order);
Object o=rabbitTemplate.convertSendAndReceive(queue2,orderId);
}...
196 просмотров
schedule
03.05.2022
Запрос/ответ RabbitMQ RabbitTemplate не настроен как слушатель
Я тестирую шаблон запроса/ответа с реализацией кролика Spring-AMQP, и я не могу заставить его работать...
У меня настроены следующие артефакты:
test_exchange с очередью приветствия. Ключ маршрутизации = приветствие answer_exchange с очередью...
1098 просмотров
schedule
08.06.2022
Обработка исключений в Spring AMQP MessagePostProcessor
Я написал MessagePostProcessor, который вызывается до вызова любого потребителя onMessage.
Теперь, если в моем MessagePostProcessor возникает какое-либо исключение, мне нужно поймать исключение, иначе сообщение будет бесконечно запрашиваться на...
555 просмотров
schedule
02.02.2023
Получение ожидания от запуска потока весенней загрузки турбины
@EnableHystrixDashboard
@EnableTurbineStream
public class MonitoringApplication {
}
приложение.yml
eureka:
instance:
prefer-ip-address: true
leaseRenewalIntervalInSeconds: 10
client:
enabled: true...
1611 просмотров
schedule
19.07.2023
Spring Rabbit: режим подтверждения = вручную с RetryTemplate не удаляет сообщение из очереди
Я делаю следующие шаги:
MessageListener получает сообщение из очереди Q1
Подтвердите сообщение
Если проверка не удалась, вызовите channel.basicReject () и переместите его в очередь недоставленных сообщений.
Иначе, скажем, сервер электронной...
959 просмотров
schedule
26.01.2023
RabbitTemplate для подключения к RabbitMQ: получение - NOT_FOUND - нет очереди
Я новичок в Spring и работаю над облачным приложением и пытаюсь использовать RabbitTemplate и RabbitMQ.
Я могу хранить данные в очереди, используя.
rabbitTemplate.convertAndSend(QUEUE_NAME, msg);
Но когда я получаю данные из той же...
5596 просмотров
schedule
10.06.2023
Удалить сообщение из Rabbit MQ после ограниченных попыток запроса
Я помещаю записи из файла в Rabbit MQ, читаю записи из очереди и вызываю службу. Для отклоненных записей я отправляю отрицательное подтверждение и повторно ставлю в очередь с помощью метода channel.basicNack. Но требование состоит в том, что нам нужно...
516 просмотров
schedule
29.08.2022
Транзакции Spring AMQP в многопоточности
Я использую Spring AMQP (реализация RabbitMQ) и пытаюсь распространить одну транзакцию на несколько потоков.
В качестве примера предположим, что есть 3 очереди, имена X, Y, Z, и сначала я получаю сообщение из очереди X, используя поток-1, а затем...
443 просмотров
schedule
04.06.2022
Контекст приложения закрыт, и ConnectionFactory больше не может создавать соединения Spring AMQP
Я реализовал многопоточность для выполнения некоторых операций в jira после получения сообщения от rabbitmq. Я использую spring amqp (версия 1.6.1)
Как только поток перехватывает исключение, я устанавливаю статус как ошибку и объект вывода, о...
1900 просмотров
schedule
18.05.2022
