Вопросы по теме 'spring-amqp'
Как прослушивать тысячи незанятых почтовых ящиков imap через spring/amqp/rabbit
Вариант использования состоит в том, чтобы сервер подключался к тысячам учетных записей электронной почты пользователей и обнюхивал входящую почту в java, предпочтительно с java mail и масштабируемой инфраструктурой типа Spring Integration/amqp/rabbit...
1431 просмотров
schedule
13.10.2022
как установить basicQos в spring amqp для справедливой отправки?
Это моя текущая весенняя конфигурация amqp
<rabbit:connection-factory id="rabbitConnectionFactory"
port="${rabbitmq.port}" host="${rabbitmq.host}" username="${rabbitmq.username}" password="${rabbitmq.password}"/>
<rabbit:admin...
2280 просмотров
schedule
03.03.2024
RabbitMQ на Java с использованием Protobuf. Разобрать полученные данные
В настоящее время я использую springAMQP для связи между java и моим узлом RabbitMQ. Я отправляю данные Protobuf.
Я хотел бы преобразовать/преобразовать/разобрать полученное сообщение в соответствующий ProtoClass.
Вот фрагмент моего конвертера:...
4248 просмотров
schedule
03.01.2024
Spring AMQP: как избежать ручного объявления многих очередей?
Создав базовую настройку spring-amqp, я вижу, что для каждого типа сообщения, которое я хочу отправить (с использованием сообщений POJO), мне нужно объявить очередь в конфигурации spring.
Итак, для каждой пары из них:...
10289 просмотров
schedule
12.11.2023
Возникли проблемы с переходом contentType из сообщения AMQP в сообщение STOMP.
Вот что у меня есть (кратко)
<int-amqp:inbound-channel-adapter
auto-startup="false"
listener-container="clientListenerContainer"
channel="fromRabbitClientChannel"
connection-factory="rabbitConnectionFactory" />
<bean...
717 просмотров
schedule
15.12.2023
Spring AMQP для нескольких пользователей
У меня есть многопользовательское приложение, в которое я включил Spring AMQP для обмена сообщениями с моим сервером RabbitMQ. После тестирования разных пользователей я заметил, что одновременный вход в систему с другой учетной записью приведет к...
124 просмотров
schedule
10.06.2024
SSL-соединение RabbitMQ с spring-amqp 1.4.3
Я пытаюсь подключиться к RabbitMQ через SSL. Я следил за документацией RabbitMQ SSL, указанной здесь https://www.rabbitmq.com/ssl.html Согласно документации RabbitMQ SSL, подключение с использованием SSLv3 и TLSv1 не рекомендуется из-за известных...
7880 просмотров
schedule
09.11.2023
Отправить MessageProperties [priority=anyInteger] при публикации сообщения в RabbitMQ
мы используем Rabbit MQ и Spring Integration в нашем проекте. Каждое сообщение имеет режим доставки, заголовок, свойства и часть полезной нагрузки. Мы хотим добавить свойства, т. е. приоритет со значением 2 (любое целое число), полезную нагрузку с...
1136 просмотров
schedule
30.10.2023
Запрос недоставленных сообщений
Есть ли какие-либо функции, встроенные в spring-amqp, которые упростили бы повторную отправку недоставленных сообщений? Я могу написать код для этого, но это похоже на такой распространенный вариант использования, который хорошо вписывается в...
1697 просмотров
schedule
24.02.2024
Каким будет поведение при создании одного RabbitListenerContainerFactory с двумя потребителями и несколькими конечными точками для прослушивания сообщений?
У меня есть требование, когда у меня есть 1 прямой обмен и 5 разных очередей, привязанных к нему с уникальным ключом маршрутизации. В основном каждая очередь предназначена для разных конечных точек потребителя. Я использую управляемый реестр...
340 просмотров
schedule
19.11.2022
RabbitTemplate получает сообщения и ставит их в очередь
Мой вопрос очень похож на этот: Прием и запрос RabbitTemplate К сожалению, он был отмечен как ответ хотя ответ не соответствует моим потребностям.
Я хочу имитировать функциональность пользовательского интерфейса Rabbit Admin, т.е. я хочу...
1898 просмотров
schedule
25.12.2023
Поведение RabbitListener с несколькими очередями
Каково поведение при использовании следующей конструкции (последняя версия Spring). Я не могу найти его в документации.
@RabbitListener(queues = {"q1", "q2", "q3"})
public class MyListener {
В каком порядке обрабатываются сообщения из трех...
2506 просмотров
schedule
28.09.2022
Создание новой очереди с использованием Spring AMQP при запуске веб-приложения
Я пытаюсь создать новую очередь в RabbitMQ, используя Spring AMQP при запуске сервера моего веб-приложения. Я не получаю точный код конфигурации, как этого добиться. Ниже мой фрагмент кода. Пожалуйста, исправьте следующее.
@Configuration
public...
79 просмотров
schedule
24.10.2023
Spring AMQP с RabbitMQ, получающим то же сообщение
У меня есть небольшое приложение для весенней загрузки rabbitmq:
@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory)
{
SimpleRabbitListenerContainerFactory factory = new...
1016 просмотров
schedule
29.04.2024
Повторите настройку для @RabbitListener, программно указав очередь недоставленных сообщений
Я пытался найти способ установить механизм повтора для всех @RabbitListener . Я уже пробовал со свойствами:
listener:
auto-startup: true
concurrency: 1
max-concurrency: 1
retry:
enabled: true
initial-interval: 1000...
3830 просмотров
schedule
25.11.2022
Как вручную получать сообщения от rabbitmq с помощью интеграции spring
[EDIT] Загрузка полных конфигураций:
rabbit.xml, который удаляется из очереди Rabbit
<rabbit:connection-factory id="amqpConnectionFactoryInbound"
host="${rabbit.host}" port="${rabbit.port}"
username="${rabbit.username}"...
2840 просмотров
schedule
25.10.2023
Интеграция Spring — разница между AmqpOutboundEndpoint и RabbitTemplate
Я пытаюсь написать свой первый издатель AMQP через интеграцию Spring, используя экземпляр AmqpOutboundEndpoint.
Я не понимаю, в чем разница между RabbitTemplate и AmqpOutboundEndPoint, поскольку AmqpOutboundEndpoint использует экземпляр...
173 просмотров
schedule
22.03.2024
Реализовать код Spring без аннотаций
Я хочу переписать этот код Spring AMQP без аннотаций:
@SpringBootApplication
public class So51009346Application {
public static final String QUEUE_PROCESSING_TRANSACTION = "q1";
public static void main(String[] args) {...
435 просмотров
schedule
24.10.2022
Ошибка типа аргумента с приемником Spring AMQP
Мое приложение Spring AMQP регистрирует следующее исключение при запуске:
org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Failed to invoke target method 'receiveMessage' with argument type = [class [B], value =...
2705 просмотров
schedule
12.12.2023
Гарантии обработки мертвых писем RabbitMQ
Если я использую подтверждения издателя, я могу (разумно) быть уверенным, что сообщение, отправленное на обмен на сервере RabbitMQ и получившее ACK от сервера RabbitMQ, не потеряно, даже если сервер RabbitMQ выйдет из строя (например, отключение...
378 просмотров
schedule
29.04.2024
