Описание тега spring-amqp
Spring components for AMQP-based messaging.
1
ответ
Как установить устойчивость очереди / сообщения в false в Spring AMQP с помощью аннотаций?
Я написал пример Spring Amqp-производителя, который работает на сервере RabbitMQ, который отправляет сообщения и использует эти сообщения, используя MessageListener, используя Spring AMQP. Здесь я хочу установить для очереди и стойкости сообщения зн…
28 авг '13 в 13:03
1
ответ
Использование TrustStore по умолчанию с SSL-соединением
При использовании SSL, RabbitConnectionFactoryBean требует как keyStore а также trustStore быть явно указанным в свойствах SSL. Я ищу способ обойти это требование, когда сервер использует известный CA, присутствующий по умолчанию trustStoreТак как р…
03 окт '16 в 09:08
2
ответа
Как разобрать объект JSON в Spring AMQP?
Существует удаленный сервер RabbitMQ, который позволяет мне только отправлять и получать сообщения. Это значит, что я не могу ничего создать. Я отправляю определенный запрос и получаю ответ в формате JSON. В моем приложении у меня есть простой класс…
03 сен '18 в 09:29
0
ответов
RabbitMQ Listener автоматически останавливается
Я использую слушатель Spring Rabbit MQ на основе шаблона При повышенной нагрузке слушатель просто выключается Как предотвратить отключение слушателя? Или как перезапустить слушатель сразу после выключения? Я использую следующий конфиг: <rabbit:co…
16 апр '14 в 11:03
1
ответ
Загружать контекст весны, даже если rabbitmq не работает
Можно ли загрузить контекст Spring с @RabbitListener, даже если брокер сообщений RabbitMQ не работает? Поведение должно быть таким же, как и в случае отключения брокера. Приложение ожидает брокера, и когда оно восстанавливается, то листернер автомат…
25 фев '16 в 12:27
1
ответ
RabbitMQ Не удалось объявить очередь, и слушатель не может получить очередь на сервере
У меня есть приложение rabbitmq для весенней загрузки, в котором я должен отправить объект Employee в очередь. Затем я настроил приложение для прослушивания. Сделайте некоторую обработку на объекте работника и поместите этот объект в очередь обратно…
17 мар '18 в 08:53
1
ответ
Пружинная пакетная интеграция удаленного чанкинга с использованием AMQP (Rabbit)
Я пытаюсь реализовать Remote Chunking как объясняется здесь http://docs.spring.io/spring-batch/trunk/reference/html/springBatchIntegration.html. Моя простая магистерская работа: <job id="job" restartable="true"> <step id="step1"> <tas…
22 июл '15 в 12:14
1
ответ
Как установить весенний amqp, издатель подтверждает и возвращает?
Я новичок в весне AMQP. Когда конфиг весны amqp издатель подтверждает и возвращает, встретились проблемы. Конфигурация amqp: SimpleMessageListenerContainer container(CachingConnectionFactory connectionFactory, @Qualifier("topicListenerAdapter")Messa…
22 мар '16 в 13:21
1
ответ
Попытка подключения потребителя весной amqp кролик макс
Я пытаюсь установить максимальное количество попыток от моего приложения к брокеру кроликов. У меня есть перехватчик повторов, @Bean public RetryOperationsInterceptor retryOperationsInterceptor() { return RetryInterceptorBuilder.stateless() .maxAtte…
21 фев '17 в 20:16
1
ответ
Есть ли способ настроить лопату программно?
Мы разрабатываем приложение Spring-AMQP - RabbitMQ. Мы хотим использовать лопатку для репликации сообщений из локальной очереди в удаленную очередь, но мы хотим сделать почти всю конфигурацию службы обмена сообщениями из весеннего приложения. На дан…
05 дек '12 в 04:04
1
ответ
Каков правильный тип исключения для NACK-сообщения с использованием прослушивателя на основе аннотаций при загрузке с использованием amqp?
Я использую Spring Boot со Spring-amqp и слушателем на основе аннотаций, чтобы получить сообщение от брокера rabbitmq. У меня есть компонент Spring, который содержит такой метод: @RabbitListener(queues = "tasks") public void receiveMessage(@Payload …
29 авг '16 в 18:11
1
ответ
Spring AMQP Java Конфигурация
У меня есть проект Maven Spring MVC, я реализовал внутренний обмен сообщениями между сервисами RabbitMQ и библиотекой spring-amqp. Это мой весенний конфигурационный код amqp java: @PropertySource({"classpath:hello.properties"}) @Configuration @Compo…
20 фев '18 в 14:42
1
ответ
java.lang.ClassCastException: JedisConnectionFactory не может быть приведен к ConnectionFactory
Я не уверен, почему метод "connectionFactory" возвращает экземпляр JedisConnecionFactory, если это не org.springframework.amqp.rabbit.connection.ConnectionFactory? Следующее исключение в строке "new RabbitTemplate(connectionFactory())" (см. Код ниже…
23 фев '15 в 12:10
1
ответ
Как подписчик темы Rabbitmq работает на кластерном сервере приложений для получения сообщений?
У меня есть Тема Кролика с несколькими (скажем, 2) подписчиками, которая работает в кластере серверов приложений со сбалансированной нагрузкой (скажем, 3) . Так будет ли сообщение доставлено всем (2 X 3) подписчикам всех слушателей в кластерной сред…
07 июл '15 в 10:35
1
ответ
Настройка Spring Integration QueueChannel для RabbitMQ
В настоящее время я использую Spring AMQP API для подключения к RabbitMQ. По сути, в моем коде пользователя я читаю сообщения асинхронно и делаю групповую вставку в упругом поиске. когда я делаю ack = AUTO, я получаю умеренную скорость 400-500 мсг /…
25 сен '13 в 14:45
0
ответов
Apache Zookeeper Curator Framework с AMQP
Я новичок в AMQP, но я хочу получить опыт работы с AMQP с Curator Framework на Apache Zookeeper, поэтому, пожалуйста, дайте мне знать, если у вас есть ссылка на пример проекта Github и полезная информация, чтобы понять это.
29 июн '16 в 12:35
2
ответа
Spring RabbitTemplate- Как получить опубликованное сообщение для NACK в режиме подтверждения Publisher
У меня есть веб-приложение, которое отправляет сообщения на RabbitQueue с помощью Spring. Я включил Publisher, подтвердил и включил возврат, и я использую шаблон весны кролика:. Это моя конфигурация: <rabbit:template id="amqpTemplate" connection-…
07 дек '15 в 01:32
1
ответ
Установить время ожидания по умолчанию с подтверждениями издателя
Я хочу реализовать пример с подтверждениями издателя AMQP, настроенными с таймаутом. Что-то вроде этого: private final CountDownLatch confirmLatch = new CountDownLatch(1); TransactionResponseFactory processingPeply = (TransactionResponseFactory) pro…
12 фев '19 в 10:59
1
ответ
Spring AMQP: при использовании программной регистрации конечной точки, как установить ключ маршрутизации?
Я использую программную регистрацию конечных точек слушателей: MethodRabbitListenerEndpoint endpoint = new MethodRabbitListenerEndpoint(); endpoint.setId(endpointId); endpoint.setQueues(eventsQueue); endpoint.setBean(hanlderMethod.bean); endpoint.se…
15 мар '16 в 15:55
1
ответ
Шаблон проверки заявок на интеграцию Spring - повторная отправка при сбое
Итак, моя установка: <int-amqp:inbound-channel-adapter channel="input-channel" queue-names="probni" message-converter="jsonMessageConverter" channel-transacted="true" transaction-manager="dataSourceTransactionManager"/> <int:chain input-cha…
09 дек '16 в 13:31