1
ответ
Тест, требующий макет RabbitTemplate
У меня есть класс реализации, который действует как класс отправителя rabbitMQ, я пытаюсь написать для этого примеры модульных тестов, но у меня есть сомнения относительно насмешливого шаблона rabbitmq. Это мой код класса отправителя: ...
вопрос задан: 21 March 2019 02:13
1
ответ
Отправлять сообщения от rabbitMQ на PostgreSQL
Я знаю, что можно отправлять сообщения из PostgreSQL в RabbitMQ, но можно ли отправлять сообщения из RabbitMQ в PostgreSQL. Прямо сейчас я кормлю RabbitMQ через плагин amqp с некоторыми ...
вопрос задан: 13 March 2019 12:24
1
ответ
Логика постановки задачи на неудачу сельдерея (RabbitMQ)
У меня есть следующие настройки: версия сельдерея = 4.2.1 task_reject_on_worker_lost = True task_acks_late = True Я пытаюсь получить сообщение для маршрутизации в "QueueA" первоначально, и если работник сельдерея это ...
вопрос задан: 5 March 2019 19:01
1
ответ
Установите AMQP в Windows 10 & amp; PHP 7.3
Я хочу установить AMQP в Windows 10 с PHP 7.3 для использования в Symfony 4. Windows не использует apache / iis / nginx и запускается непосредственно Symfony. все нормально! пока я не решу использовать rabbitmq в проекте ...
вопрос задан: 3 March 2019 09:03
1
ответ
RabbitMQ для чата и многоадресной рассылки
Предположим, у меня есть простое приложение чата, где некоторые клиенты могут публиковать сообщения на каком-то канале X, а некоторые клиенты хотят подписаться на все сообщения в X (многоадресная рассылка на основе каналов). Буду ли я ...
вопрос задан: 2 March 2019 20:30
1
ответ
EasyNetQ Подписаться не работает с TopShelf
Я новичок в этой комбинации RabbitMQ, EasyNetQ, TopShelf. На данный момент я не использую DI. Я пытаюсь подписаться на очередь с помощью EasyNetQ. Подписаться работает с этим кодом консольного приложения ...
вопрос задан: 27 February 2019 16:32
1
ответ
Celery и RabbitMQ не запускаются
Я установил RabbitMQ, Celery, Flask и Python, но когда я попытался запустить работника сельдерея для тестирования. Это не работает, это ошибка, которая выскакивала в cmd. [2019-01-18 09: 56: 37,443: ВНИМАНИЕ / ...
вопрос задан: 14 February 2019 08:31
1
ответ
Сохраняет ли RabbitMQ открытую связь для потребителя?
Я пытаюсь реализовать решение RabbitMQ в среде, где все соединения должны быть запущены из безопасной зоны в менее безопасную зону. Стандартная реализация RabbitMQ предусматривает ...
вопрос задан: 8 February 2019 16:27
1
ответ
Слушатель очередей конфигурации RabbitMQ в файле YAML
Прежде всего, я извиняюсь за мой английский. Я делаю работу в средней школе, и мне нужно настроить имя очереди RabbitMQ в файле YAML для моего слушателя, а я не смог. Я сделал приложение, используя ...
вопрос задан: 19 January 2019 18:05
1
ответ
Rabbitmq не сохраняет сообщение в обмен, если нет подписчика?
У меня есть следующие издатель и подписчик: // publisher.js var amqp = require ('amqplib / callback_api'); amqp.connect ('amqp: // localhost', function (err, conn) {conn.createChannel (function (err, ...
вопрос задан: 18 January 2019 17:34
1
ответ
Azure Devops - Docker Compose Сборка образа не найдена
У меня проблема с получением образа для сборки в Devure Azure из файла docker-compose. Похоже, что первая проблема заключается в том, что изображение не строит. Это, я полагаю, вызывает шаг толчка ...
вопрос задан: 18 January 2019 16:41
1
ответ
RabbitMQ + Reactor, отправляющий ACK после передачи сообщения?
Я пытаюсь выяснить, является ли Project-Reactor приемлемым вариантом для моего варианта использования. Мне нужна высокая согласованность в моем приложении, я хочу: Получить сообщение от RabbitMQ Выполнить некоторые манипуляции / ...
вопрос задан: 17 January 2019 12:05
1
ответ
Трассировка исключения в заголовке сообщения в очереди недоставленных сообщений
Я использую Spring-Cloud-Stream для получения сообщения от Rabbit MQ. У меня есть очередь и привязка к мертвой букве. Всякий раз, когда возникает какое-либо исключение, сообщения направляются в очередь недоставленных сообщений. ...
вопрос задан: 16 January 2019 10:38
1
ответ
Издатель RabbitMQ подтверждает заказ
Я пишу обертку вокруг библиотеки .NET RabbitMQ, и, насколько я вижу, у меня есть вопрос, на который нет ответа в документации, и я не могу придумать способ экспериментальной проверки. Итак, я был ...
вопрос задан: 16 January 2019 10:08
1
ответ
spring rabbitmq получить все ответы на сообщение о перевоспитании
Следующий класс включен в несколько пользовательских приложений: @Component @Configuration открытый класс HealthListener {public static final String HEALTH_CHECK_QUEUE_NAME = "healthCheckQueue" ...
вопрос задан: 15 January 2019 22:38
1
ответ
RabbitMQ - публикация в очереди или обмен
Меня немного смущают лучшие практики RabbitMQ в отношении использования очередей и обменов. Допустим, я хотел бы доставить сообщение GenerateInvoice с некоторыми данными для счета и иметь несколько ...
вопрос задан: 15 January 2019 20:30
1
ответ
Как отправить электронное письмо для сброса пароля Django с помощью Celery (без стороннего пакета)?
Прежде всего, я знаю, что на этот вопрос ранее уже был дан ответ, который использует сторонний пакет django-celery-email, но я пытаюсь выяснить, как сделать такую работу, не передавая ни на что ...
вопрос задан: 15 January 2019 15:32
1
ответ
Как получить RabbitMQ для чтения из очереди один за другим?
Я просто играю с RabbitMQ и пытаюсь получить тестового отправителя и получателя, настроенного в двух проектах C #. TestSender.cs с использованием системы; использование RabbitMQ.Client; используя System.Text; публичный класс ...
вопрос задан: 13 July 2018 19:54
1
ответ
Почему работник сельдерея дает & ldquo; OSError: Socket closed & rdquo;
Мой работник сельдерея, который работает с rabbitMQ, продолжает давать мне ошибку сокета - см. Ниже - после работы в течение нескольких минут. Я хотел бы знать, что может быть основной причиной проблемы? Я думал так ...
вопрос задан: 13 July 2018 17:55
1
ответ
Конфигурация обработки ошибок MassTransit
У меня возникла проблема с настройкой потребителя ошибок в моем приложении. Проблема в том, что потребляемое сообщение передается в очередь * _error_skipped, и оно не исчезает полностью. Ниже очень просто ...
вопрос задан: 13 July 2018 12:04
1
ответ
Inno Setup не может получить доступ к файлу cookie RabbitMQ Erlang в папке Windows \ system32 \ config? [Дубликат]
Я пытаюсь скопировать файл из папки Windows \ system32 \ config \ systemprofile. В частности, я пытаюсь скопировать файл .erlang.cookie из этой папки в папку «Пользователь», чтобы «синхронизировать» этот файл cookie ...
вопрос задан: 19 January 2016 15:53
1
ответ
RabbitMQ / Сельдерей с Django держится, задерживаться/подготавливать/и т.д. - Никакая полезная информация о журнале
Таким образом, я просто устанавливаю сельдерей и rabbitmq, создал моего пользователя, установите vhost, отобразил пользователя на vhost и выполнил демона сельдерея успешно (или таким образом, я принимаю) (queuetest) corky@corky-server: ~/projects/...
вопрос задан: 19 December 2015 11:35
1
ответ
RabbitMQ C # API Потребление сообщений на основе событий
while (true)
{BasicDeliverEventArgs e = (BasicDeliverEventArgs) Consumer.Queue.Dequeue (); IBasicProperties properties = e.BasicProperties; byte [] body = e.Body; Console.WriteLine ("...
вопрос задан: 19 December 2012 10:28
1
ответ
Проверьте размер очереди RabbitMQ от клиента
Кто-либо знает, существует ли способ проверить количество сообщений в очереди RabbitMQ от клиентского приложения? Я пользуюсь клиентской библиотекой.NET.
вопрос задан: 10 August 2012 14:05
1
ответ
Производство действительно ли AMQP готово?
Я хотел бы использовать AMQP для присоединения к двум сервисам один записанный в C# и другой записанный в Python. Я ожидаю довольно большой объем сообщений в секунду. Есть ли какой-либо Брокер AMQP, который является готовым производством?...
вопрос задан: 9 July 2012 15:32
1
ответ
减少RabbitMQ内存使用率
我正在尝试在小型VPS上运行RabbitMQ（ 512mb RAM）以及Nginx和其他一些程序。 我已经能够毫无困难地调整其他所有设备的内存使用情况，但是我似乎无法得到...
вопрос задан: 22 December 2011 17:54
1
ответ
Прерывание выполняющейся задачи в Celery внутри django
Я хотел бы иметь возможность прервать выполнение задачи, выполняющейся из очереди Celery (с использованием rabbitMQ). Я вызываю задачу, используя task_id = AsyncBoot.apply_async (args = [name], name = name, connect_timeout = 3), где ...
вопрос задан: 26 August 2010 15:11
1
ответ
Как выборочно удалить сообщения из AMQP (RabbitMQ) очередь?
Я хотел бы выборочно удалить сообщения из очереди AMQP, даже не читая их. Сценарий следующие: Отправка стороны хочет истечь сообщения типа X на основе того, что новая информация...
вопрос задан: 8 August 2010 15:03
1
ответ
Как сделать обработку отказа очередей RabbitMQ?
Поддержки RabbitMQ, кластеризирующиеся по умолчанию, но очереди, не копируются и связываются с узлом, на котором они создаются. Я теперь ищу способы сделать RabbitMQ высоконадежным кроме DRBD...
вопрос задан: 5 August 2010 09:35
1
ответ
Маршрутизация с учетом информационного наполнения с RabbitMQ и Python
Действительно ли возможно с RabbitMQ и Python сделать маршрутизацию с учетом информационного наполнения? Стандарт AMQP и RabbitMQ утверждают, что поддерживали маршрутизацию с учетом информационного наполнения, но являются там любыми библиотеками для Pytho
вопрос задан: 19 July 2010 11:37