12
ответов

Получение исключения NullPointerException при попытке создать RMQSink во Flink [дубликат]

Я пытаюсь сделать Sink для Flink, чтобы отправлять сообщения от Flink до RabbitMQ. Когда я создаю Sink в основном, все работает нормально - я получаю сообщение в специальной очереди на RabbitMQ. ...
вопрос задан: 26 May 2016 16:15
7
ответов

ActiveMQ или RabbitMQ или ZeroMQ или [закрыто]

Нам было бы интересно узнать, какие плюсы и минусы у ActiveMQ против RabbitMQ против ZeroMQ. Информация о любых других интересных очередях сообщений также приветствуется.
вопрос задан: 27 February 2014 07:04
5
ответов

Что такое MQ и почему я хочу использовать его?

В моей команде на работе мы используем технологию MQ IBM много для перекрестной связи приложений. Я видел в последнее время на Hacker News и других местах о других технологиях MQ как RabbitMQ. У меня есть основное...
вопрос задан: 19 May 2010 19:38
4
ответа

за подтверждение сообщения в Kafka / RabbitMQ

У нас есть рабочий кролик. Реализация, из-за объема, мы планируем перейти на кафку. У меня есть сомнения в одном месте. В rabbitMQ, когда потребитель потребляет сообщение от Q, сообщение ...
вопрос задан: 2 March 2019 23:24
4
ответа

В c # передать функцию из другого класса, не ставя ее [duplicate]

Обратите внимание, что этот подобный звуковой вопрос на самом деле не отвечает на мой вопрос. У меня есть класс, который включает в себя чтение сообщения из очереди и его обработку. Я пытался использовать метод в другом ...
вопрос задан: 15 December 2014 16:35
4
ответа

Почему использование AMQP/ZeroMQ/RabbitMQ

в противоположность записи Вашей собственной библиотеки. Мы работаем над проектом здесь, который будет самоделящимся пулом сервера, если один раздел станет слишком тяжелым, менеджер разделил бы его и поместил бы его на другого...
вопрос задан: 17 February 2014 11:23
4
ответа

Среда Демона/рабочего PHP

Проблема: Я хочу реализовать несколько php-рабочих-процессов, кто слушает на очереди MQ-сервера для асинхронных заданий. Проблема теперь состоит в том, что, просто работая это обрабатывает как демоны на сервере...
вопрос задан: 16 April 2012 14:55
4
ответа

Ожидайте единственного сообщения RabbitMQ с тайм-аутом

Я хотел бы отправить сообщение на сервер RabbitMQ и затем ожидать ответного сообщения (на "ответе -" очереди). Конечно, я не хочу ожидать навсегда в случае, если приложение, обрабатывающее эти сообщения...
вопрос задан: 10 May 2010 00:26
4
ответа

Преимущества коммерческого промежуточного программного обеспечения обмена сообщениями по сравнению с открытым исходным кодом

Я оценивал несколько технологий очереди сообщений с открытым исходным кодом, таких как RabbitMQ, ActiveMQ, OpenAMQ, и т.д. Мой вопрос, какая выгода получена при помощи коммерческой технологии, такой как Tibco...
вопрос задан: 28 September 2009 21:17
3
ответа

Что именно означает «частичная функция» в функциональном программировании?

Насколько я понимаю, частичные функции - это функции, которые мы получаем, передавая в функцию меньше параметров, чем ожидалось. Например, если это было правильно в Python: >>> ...
вопрос задан: 11 October 2019 16:19
3
ответа

Дизайн схемы MongoDB - чат в режиме реального времени

Я запускаю проект, который я думаю, будет особенно подходить для MongoDB из-за скорости и масштабируемости, которую это предоставляет. Модуль, которым я в настоящее время интересуюсь, относится к чату в режиме реального времени. Если я был...
вопрос задан: 22 September 2017 18:01
3
ответа

Я могу использовать Лицензию 1.1 Общественности Mozilla (MPL) в коммерческом приложении? [закрытый]

Существует несколько потоков, говорящих о проблеме лицензии. Главным образом фокусировка на GPL/LGPL/BSD. Я пытаюсь использовать RabbitMQ в коммерческом применении, который лицензируется в соответствии с Лицензией общественности Mozilla (MPL)...
вопрос задан: 12 August 2015 23:55
3
ответа

Простой способ установить RabbitMQ в Ubuntu?

Есть ли простой способ установить RabbitMQ для Ubuntu? Я сделал следующее: Добавьте в /etc/apt/sources.list следующую строку: deb http://www.rabbitmq.com/debian/ testing main, затем установите ...
вопрос задан: 20 November 2012 14:22
3
ответа

повторно поставьте задание предприятия с потогонной системой в очередь в RabbitMQ

Я работаю над приложением направляющих, где клиент возмещает, вручены рабочему Предприятия с потогонной системой. Если возмещение перестало работать (потому что мы не можем достигнуть платежного процессора в то время), я хочу повторно поставить задание в
вопрос задан: 5 January 2010 13:04
3
ответа

Как установить обнаружение тайм-аута на сервере RabbitMQ?

Я испытываю RabbitMQ с этой привязкой Python. Одна вещь, которую я заметил, состоит в том, что, если я уничтожаю потребителя грязно (эмулирующий разрушенную программу), сервер будет думать, что этот потребитель все еще там...
вопрос задан: 8 October 2009 14:34
2
ответа

RabbitMQ DefaultConsumer вызывает слишком много потребительских тегов

У меня есть клиентское приложение RabbitMQ, которое слушает определенную очередь. Клиент создает и экземпляр DefaultConsumer и реализует метод handleDelivery. Вот код защищен ...
вопрос задан: 18 January 2019 21:14
2
ответа

Как проверить, существует ли очередь сообщений RabbitMQ или нет?

Как проверить, существует ли очередь сообщений уже существует или нет? У меня есть 2 разных приложения, одно из которых создает очередь, а другое читает из этой очереди. Поэтому, если я запускаю Клиент, который читает из ...
вопрос задан: 23 August 2017 16:06
2
ответа

Обнаружение отключения RabbitMQ в Java Client [дубликат]

Можно ли обнаружить отключение Java-клиента RabbitMQ? В частности, цель заключается в том, чтобы приложение было осведомлено о возможной потере сообщений. Заранее спасибо!
вопрос задан: 27 September 2014 03:25
2
ответа

Используя RabbitMQ (клиент Java), там способ определить, закрывается ли сетевое соединение во время, используют?

Я использую RabbitMQ на RHEL 5.3 с помощью клиента Java. У меня есть 2 узла (машины). Node1 использует сообщения от очереди на Node2 с помощью класса помощника Java QueueingConsumer. QueueingConsumer...
вопрос задан: 13 July 2014 09:59
2
ответа

RX против очередей сообщений, таких как rabbitmq или zeromq? [закрыто]

Я совершенно новичок в этих парадигмах параллелизма высокого уровня и начал использовать привязки scala RX. Поэтому я пытаюсь понять, чем RX отличается от очередей обмена сообщениями, таких как RabbitMQ или ZeroMQ? Oни ...
вопрос задан: 11 January 2014 10:29
2
ответа

Как правильно управлять rabbitmq с помощью supervisord

Текущий раздел в моем supervisord.conf выглядит так: [program: rabbitmq] command = / usr / sbin / rabbitmq-server Когда я пытаюсь остановить rabbitmq с супервизором (supervisorctl stop rabbitmq), ...
вопрос задан: 12 October 2011 04:51
2
ответа

RabbitMQ.Client потребляет несколько очередей [дубликат]

Я довольно новичок в RabbitMq, и я пытаюсь разработать свое первое приложение .NET Core, которое прослушивает две разные очереди, а затем обрабатывает запросы. Сценарий следующий: Asp.Net MVC отправляет ...
вопрос задан: 20 July 2011 16:10
2
ответа

Rabbitmq или Gearman - выбор [закрытой] очереди заданий

На работе мы должны создать сервер заданий для вещей как отправка электронных писем, создание PDFs, уплотнение некоторых данных, и т.д. Очевидно, мы хотели бы основываться на своего рода универсальной системе массового обслуживания. Я знаком...
вопрос задан: 29 March 2011 23:03
2
ответа

Какой я должен выбрать AMQP или XMPP для игры на базе браузера в реальном времени?

Я выбираю между AMQP (RabbitMQ) по сравнению с XMPP (eJabberd) для приводимой в действие основанной на повороте игры моего JavaScript без флэш-памяти на базе браузера в реальном времени. Я не знаю много о AMQP и протоколе XMPP. Я хотел бы...
вопрос задан: 30 May 2010 15:40
2
ответа

Делает RabbitMq, делают циклический алгоритм от обмена до очередей

Я в настоящее время оцениваю системы очереди сообщений, и RabbitMq походит на хорошего кандидата, таким образом, я рою немного больше в него. Для предоставления небольшого контекста, я надеюсь иметь что-то как одно...
вопрос задан: 7 April 2010 21:59
2
ответа

Простая масштабируемая работа/очередь сообщений с задержкой

Я должен настроить задание/очередь сообщений с опцией установить задержку задачи так, чтобы это не было сразу взято свободным рабочим, но после определенного времени (может варьироваться от задачи до задачи). Я...
вопрос задан: 2 March 2010 16:17
2
ответа

Высокая скорость RabbitMQ переходное выполнение обмена сообщениями

Система, которую мы создаем, получает данные через внешний канал. Наше задание состоит в том, чтобы распределить эти данные многочисленным услугам, выполнить вычисления и передать результаты в другом месте - типичный...
вопрос задан: 23 January 2010 18:47
2
ответа

Я должен использовать Сельдерей или Морковь для проекта Django?

Я немного смущен, относительно которого я должен использовать. Я думаю или буду работать, но один лучше или более соответствующий, чем другой? http://github.com/ask/carrot/tree/master http://github.com/ask/...
вопрос задан: 9 July 2009 07:05
1
ответ

Высокая доступность и балансировка нагрузки в RabbitMq

Рассмотрим кластер с узлами A и B, я хочу решение, которое удовлетворяет следующим требованиям: 1) Когда узел A выходит из строя, система продолжает работать должным образом с узлом B до тех пор, пока узел A снова не появится 2) ...
вопрос задан: 28 March 2019 04:45
1
ответ

Тест, требующий макет RabbitTemplate

У меня есть класс реализации, который действует как класс отправителя rabbitMQ, я пытаюсь написать для этого примеры модульных тестов, но у меня есть сомнения относительно насмешливого шаблона rabbitmq. Это мой код класса отправителя: ...
вопрос задан: 21 March 2019 02:13