Описание тега easynetq

EasyNetQ - это простой в использовании и самоуверенный.NET API для RabbitMQ.
2 ответа

Ошибка отправки сообщения в очередь

Я использую EasyNetQ для отправки сообщения в очереди кролика. У меня есть такой код using (var bus = RabbitHutch.CreateBus("MyConnection")) { bus.Send("MyCodeName", "MyClass"); } соединение открыто при создании шины, но при отправке сообщения возни…
01 июл '16 в 09:21
1 ответ

Очередь FIFO, чтобы гарантировать упорядоченную "обработку" сообщений (несколько потребителей)?

Мне задали этот вопрос сегодня, и ответ, кажется, разделяет мнение среди моей команды. Сценарий У вас есть несколько издателей, отправляющих события (сообщения) в RabbitMQ (через EasyNetQ) по определенным темам. Они сказали, что они гарантируют FIFO…
08 дек '16 в 08:05
0 ответов

RabbitMq Архитектурное решение для приложения Distributed Desktop

Мы переписываем некоторую часть нашего приложения Retail ERP, которое было написано в Windows-приложении.net 4.0 с внутренними службами, подключенными через.Net. Мой вопрос является последующим и обновленным вопросом о том, что я нахожу здесь ( Rabb…
20 май '17 в 08:53
2 ответа

Как десериализовать сообщение с мертвой буквой, когда неформатная буква меняет тип?

Я пытаюсь написать службу обработки мертвых писем, которая считывает сообщения из очереди мертвых писем, а затем что-то делает с сообщениями в зависимости от типа, содержимого и т. Д. В моем приложении C# я использую EasyNetQ. У меня есть базовый ти…
23 фев '17 в 21:50
1 ответ

Мое приложение asp.net mvc 4 не отправляет / не публикует rabbitmq

У меня есть приложение, приложение asp.net MVC 4. Я хочу использовать rabbitmq с easynetq. В моем локальном компьютере это работает отлично. Но в производственной среде, которая является Windows Server 2012, он не отправляет никаких сообщений. Я не …
16 дек '15 в 08:41
1 ответ

Как уведомить приложение AngularJS от EasyNetQ

Таким образом, у меня есть следующая архитектура: Angular SPA (одностраничное приложение) выполняет вызов к контроллеру.NET Web API, который публикует сообщение в оконную службу EasyNetQ Publisher, которая отправляет асинхронный запрос во вторую око…
23 май '16 в 19:27
3 ответа

Микросервис и RabbitMQ

Я новичок в Microservices и у меня есть вопрос с RabbitMQ / EasyNetQ. Я отправляю сообщения из одного микросервиса в другой микросервис. Каждый микросервис является веб-API. Я использую CQRS, где мой командный обработчик будет получать сообщения из …
0 ответов

Измените соединение EasyNetQ на лету

Я храню мою строку подключения RabbitMQ в базе данных, чтобы я мог изменить ее на лету, но, учитывая, что службы EasyNetQ предназначены для настройки и IoC регистрируются как одноэлементные во время начальной загрузки приложения, кажется, что практи…
06 мар '16 в 15:44
1 ответ

Невозможно реализовать множественный обработчик для потребителя в RabbitMQ с использованием клиента EasynetQ для.Net

Я использую решение Rabbitmq Queue, и у меня есть 4 очереди и один потребитель. я хочу, чтобы мой потребитель использовал все эти очереди и предоставлял отдельный обработчик для каждой из них. Я прогуглил это и обнаружил, что Rabbitmq и EasyNetQ (.N…
13 июл '15 в 11:29
1 ответ

Как узнать, когда все подписчики заполнены?

У нас есть куча запросов, которые мы планируем опубликовать в очереди. Будет несколько разных типов подписчиков, каждый в своем круглом пуле. Например, Request1 помещается в очередь LoggingSubscriber1 и LoggingSubscriber2 подписываются с подпиской "…
11 окт '13 в 21:08
1 ответ

Реализация шаблона рабочей очереди с драйвером easynetq на rabbit mq

Как реализовать рабочую очередь в rabbit mq с помощью драйвера easynetq? Также желательно подтверждение как издателя, так и подписчика. Идея состоит в том, что одно сообщение будет обрабатываться только одним подписчиком. Это поведение по умолчанию …
17 май '16 в 03:45
2 ответа

MVC - WCF - RabbitMQ - Событие домена через очередь сообщений для ускорения потребителя или альтернативы?

Управляемый доменом дизайн Передача событий в отдельные контексты Пользовательское действие в MVC должно генерировать событие, которое передается удаленному (той же локальной сети) обработчику события. Что я проверял: MVC: вызов службы запускается и…
0 ответов

EasyNETQ System.StackruException с Ninject DI

Я использую Ninject version="3.2.2.0" и последнюю версию EasyNetQ 0.63.5.454. Я создал простой проект. static class Program { static void Main() { var kernel = new StandardKernel(new NinjectSettings(){LoadExtensions = true}); kernel.Load<MyModule…
18 янв '17 в 11:10
0 ответов

Как правильно настроить WebApi, EasyNetQ и Ninject?

Это то, что я имею до сих пор. Я застрял в концепции / где реализовать точку ввода / создания IBus (издатель). Я пытался сохранить функциональность издателя в рамках всего проекта, а не создавать для него отдельный сервис. bus = RabbitHutch.CreateBu…
15 май '15 в 16:46
0 ответов

Как вы вызываете методы ожидания в easyNetQ

С EasynetQ мой подписчик ожидает HttpClient.SendAsync(). Я не хочу использовать subscriberAsync(), потому что тогда порядок моих сообщений не сохраняется. Поэтому я хочу сохранить порядок своих сообщений. Как мне это сделать?
03 фев '19 в 03:35
1 ответ

Следует ли мне избегать использования асинхронных методов, если я хочу сохранить порядок сообщений в EasyNetQ?

Я видел это в документации EasynetQ " EasyNetQ реализует отдельный поток-потребитель для каждого экземпляра IBus, поэтому, если вы используете стандартный метод не асинхронной подписки, ваш обработчик сообщений будет запускаться синхронно в том же п…
03 фев '19 в 15:33
2 ответа

Отключение модели EasyNetQ

Я реализую простой клиент для RabbitMQ, используя EasyNetQ. После подключения я получаю уведомление "Модель выключения для очереди". Вот мой код: var _bus = RabbitHutch.CreateBus(String.Format("host={0}", hostName)).Advanced; var _exchange = Exchang…
08 мар '13 в 09:21
0 ответов

RabbitMQ - erl.exe высокая загрузка процессора в Windows

Мой экземпляр EC2 потребляет 100% ЦП после установки RabbitMQ. Также иногда 2 экземпляра erl.exe видны в диспетчере задач. Я погуглил эту проблему, но не смог найти решение. Я только начал с RabbitMQ и не очень разбираюсь в том, что проверять. Пожал…
25 сен '18 в 12:03
0 ответов

Тематическая маршрутизация с неуниверсальным EasyNetQ не фильтрует

Мы собираемся разместить данные между приложением C++ и приложением.NET Поскольку типы не могут быть одинаковыми, я выбрал неуниверсальную подписку. bus.Subscribe(typeof(string), "my_subscriptionId", messageStr => { TextMessage txtMsg = JsonConve…
11 фев '19 в 22:08
0 ответов

EasyNetQ - Как сохранить RetryCount в теле сообщения / заголовке?

Я использую EasyNetQ и мне нужно повторить неудачные сообщения в исходной очереди. Проблема заключается в том, что, хотя я успешно увеличиваю переменную TriedCount (в теле каждой msg), когда EasyNetQ публикует сообщение в очередь ошибок по умолчанию…