Вопросы по теме 'spring-rabbit'
Где XSD весеннего кролика (расположение схемы для кролика: пространство имен)
http://static.springsource.org/spring-amqp/docs/1.0.x/reference/html/ упоминается пространство имен rabbit: , но никогда не упоминается расположение схемы. Поиск в Google (и соглашения об именах) закончился:...
5806 просмотров
schedule
27.01.2023
Spring-amqp — более новый прослушиватель вызовов
Извините, я новичок в мире amqp . Я пытаюсь написать простое приложение:
public class HelloApp {
public static void main(String[] args) {
ApplicationContext context = new ClassPathXmlApplicationContext("spring-config.xml");
final...
1019 просмотров
schedule
25.07.2022
Поместите неподтвержденное сообщение (в случае исключения) в другую очередь в RabbitMQ
В качестве исключения при обработке сообщения из RabbitMQ я просто хотел отменить подтверждение и вместо этого поместить конкретное сообщение в другую очередь или повторно поставить в очередь в ту же очередь или полностью отбросить сообщение (согласно...
3721 просмотров
schedule
13.02.2023
SimpleMessageListenerContainer прекращает потребление из RabbitMQ при перезапуске основного узла RabbitMQ.
Когда RabbitMQ настроен для работы в качестве кластера, а основной узел перезапущен, тогда org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer не может восстановить и не может использовать сообщения (из RabbitMQ).
версия...
7103 просмотров
schedule
25.01.2024
Как я могу устранить ошибку RabbitMQ ShutdownSignalException?
Я запускаю кучу тестов в проекте, который я поддерживаю, который запускает очередь RabbitMQ. Насколько я могу судить, я никак не взаимодействую с очередью RabbitMQ. Но периодически я получаю ShutdownSignalException , что, кажется, влияет на мой...
2611 просмотров
schedule
02.09.2022
Лучшие практики канала RabbitMQ
Я создаю API REST для отправки сообщения RabbitMQ и пытаюсь понять, как лучше всего создавать/закрывать каналы. Я использую клиентский API RabbitMQ Java.
В настоящее время у меня есть класс RabbitMQPublisherConnection , где я подключаю соединение...
3319 просмотров
schedule
15.12.2023
Все подписчики не получили сообщение в кластерном приложении с весенней интеграцией rabbitmq
Я разрабатываю демонстрационное приложение чата с использованием Spring Integration, Websocket и RabbitMQ server. Когда я запускаю приложение на одном сервере, оно работает нормально.
Все сообщения, отправленные производителем, принимаются...
749 просмотров
schedule
20.04.2022
RabbitMQ: расчет на стороне сервера для каждого полученного сообщения
Я работаю с RabbitMQ и хочу на стороне сервера проводить вычисления каждый раз, когда Exchange получает сообщение.
У меня есть очередь для оценок, и когда получено слишком много плохих отзывов (скажем, больше десяти), потребитель должен быть...
276 просмотров
schedule
23.09.2022
Spring SimpMessagingTemplate
У меня есть приложение, которое получает некоторые данные от RabbitMQ. Все работает нормально, я имею в виду в классе, где у меня есть аннотация @EnableScheduling.
@Scheduled(fixedDelay = 5000)
public void volumeGraphData() {
Random r = new...
1582 просмотров
schedule
21.01.2023
Воссоздайте все соединения весеннего кролика CachingConnectionFactory
У меня есть CachingConnectionFactory с несколькими адресами. Когда один брокер падает, он подключается ко второму. Теперь, когда брокер снова появляется, мне нужно уничтожить существующие соединения и снова подключиться к нему. Но у...
773 просмотров
schedule
01.09.2022
как использовать @queuebinding с @rabbitlistener?
Кажется, начиная с версии 1.5 spring-amqp появилась новая аннотация @queuebinding。Но как ее использовать, я не знаю, можно ли ее использовать в классе или методе? Существует ли какой-либо пример?
11410 просмотров
schedule
11.02.2023
spring amqp ConfirmCallback CorrelationData иногда имеет значение null
Я включаю подтверждение публикации и вызываю метод отправки RabbitTemplate с CorrelationData. Но когда я получаю CorrelationData в ConfirmCallback, иногда CorrelationData имеет значение null, а подтверждение — true. Я должен добавить суждение...
778 просмотров
schedule
02.04.2023
Spring Integration Http + amqp rabbitmq-Concurrency Проблемы для 100 пользователей
Я использую spring Http Integration и amqp для rabbit mq, его сбой при нагрузочном тестировании для одновременных пользователей... Счетчики сообщений, которые отображаются в счетчиках сообщений jmeter и rabbitmq, не совпадают. Он отлично работает до...
134 просмотров
schedule
14.12.2022
Как написать интеграционный тест для аннотации @RabbitListener?
Мой вопрос действительно является продолжением вопроса к
Тест интеграции RabbitMQ и потоковая передача
Там говорится, что нужно обернуть «ваших слушателей» и передать CountDownLatch, и в конечном итоге все потоки объединятся. Этот ответ...
4072 просмотров
schedule
08.01.2024
Spring Интеграция Java DSL + Activiti
Я посмотрел видео о Spring + Activiti https://m.youtube.com/watch?v=0PV_8Lew3vg . Мне нужно, чтобы процесс был немедленно перемещен в serviceTask , где Activiti вызывает мой шлюз, отправляя сообщение запроса в очередь (rabbitMQ). После отправки...
445 просмотров
schedule
11.11.2022
как я могу получить correlationId?
В моем проекте (spring-rabbit ..), установите фиксированную очередь ReplyTo в шаблоне, я использую метод convertSendAndReceive для RPC.
Я понимаю, что автоматически меняет значение correlationId.
Могу ли я установить correlationId перед...
1736 просмотров
schedule
30.11.2023
spring-amqp нулевое использование потребителя с не потокобезопасным слушателем
Мы столкнулись с проблемой в производственной среде, когда потребители не используют ресурсы, а очереди продолжают расти, а производительность снижается.
Каждый из потребителей представляет собой контейнер, который содержит один экземпляр не...
111 просмотров
schedule
18.05.2022
Добавьте метод по умолчанию перед вызовом onMessage, если MessageListener Spring Amqp
Мне нужно добавить некоторые функции по умолчанию, которые будут выбирать какое-то значение из заголовка сообщения в Spring Amqp перед вызовом функции onMessage реализующего класса.
Eg
class TestListener implements MessageListerner {
public...
125 просмотров
schedule
17.03.2023
Как прочитать заголовок x-death недоставленного сообщения RabbitMQ с помощью Spring Boot?
Я пытаюсь реализовать перенаправление недоставленных сообщений, как описано в этом ответе . Я использую конфигурацию Spring. Я понятия не имею, как читать заголовки, чтобы получить исходный ключ маршрутизации и исходную очередь. Ниже приведен мой...
5075 просмотров
schedule
14.11.2022
Как отключить счетчик предварительной выборки RabbitMQ с помощью SimpleMessageListenerContainer
RabbitMQ предлагает возможность дополнительно установить счетчик предварительной выборки.
Используя spring-amqp SimpleMessageListenerContainer , я заметил, что счетчик предварительной выборки всегда установлен. Я не могу установить счетчик...
1547 просмотров
schedule
28.03.2023
