Описание тега apache-nms
Apache NMS - это C# проект, который определяет API в стиле JMS, называемый NMS, и реализует клиентов для служб обмена сообщениями, таких как ActiveMQ и Tibco EMS.
2
ответа
.Net NMS.ActiveMQ я должен хранить сеанс и связь между сообщениями отправлять вызовы
Я только начал с ActiveMQ и получил несколько вопросов. Я должен отправлять сообщения, используя ActiveMQ Что я сделал сейчас: public class ActiveMQSender { private readonly Uri connectionUri; private readonly IConnectionFactory connectionFactory; p…
13 дек '12 в 13:52
1
ответ
Отказоустойчивый транспортный протокол не может обрабатывать сообщения управления потребителем
Как часть AbortSlowConsumerStrategy, Active MQ отправляет команду на закрытие потребителя, если он обнаруживает, что потребитель работает медленно, но на стороне потребителя / клиента реализация протокола отработки отказа при сбое, по-видимому, не о…
03 апр '17 в 19:20
0
ответов
Почему Connection.Start() зависает при отказоустойчивом протоколе, даже если transport.startupMaxReconnectAttempts=1
У меня есть служба Windows C#, у которой есть потребитель, подключенный к Apache NMS.ActiveMQ, и прослушивающий очередь сообщений. Я занимаюсь вопросами переподключения, когда AMQ умирает. У меня проблема со сценарием, когда моя служба запускается в…
15 фев '19 в 12:55
3
ответа
Почему потребитель не создан для очереди ActiveMQ Temp?
Кроме SimpleMessageListenerContainer опция, потребитель не создан для временной очереди. Я не буду использовать SimpleMessageListenerContainer по некоторым вопросам, с которыми здесь сталкиваются . Следующий код не работает...(даже временная очередь…
02 май '12 в 07:11
1
ответ
Как я могу добавить пользовательские свойства к сообщению с Apache.NMS.ActiveMQ (C#)?
Я начинаю с ActiveMQ в C#. Я сериализую свой объект в JSON и отправляю его без проблем. Я бы добавил свойства к своему сообщению, но мне это не удалось. Я видел setIntProperty (имя строки, значение int) на нескольких веб-сайтах, но я не нахожу его н…
25 ноя '14 в 13:20
1
ответ
Apache NMS Получение количества ожидающих сообщений
Я пытаюсь получить текущее количество сообщений в очереди activeMQ, используя C#. Я нашел эту ссылку (которая довольно старая) ActiveMQ с C# и Apache NMS - подсчет сообщений в очереди, но перечисление очереди кажется большой работой для этой простой…
29 ноя '17 в 18:40
1
ответ
Как мне получить JMS-заголовок JMS из моего сообщения?
Я хочу вычесть заголовок JMSMessageID из моего сообщения, используя apache nms. С сообщением. Свойства [] я могу получить доступ только к свойствам своего сообщения, как мне получить JMSMessageID? Я попробовал приведенный ниже код безуспешно. ITextM…
26 июн '17 в 07:34
1
ответ
Как удалить / удалить подписчика ActiveMQ с помощью NMS API
Мне нужно удалить / удалить мою тему подписчика. Я нашел этот http://activemq.apache.org/manage-durable-subscribers.html Тем не менее, это не достаточно хорошо для нас. Мы хотим контролировать сроки удаления подписчика, и не важно, есть ли сообщение…
22 апр '13 в 10:03
3
ответа
Поддерживает ли.Net core 2.0 пакеты Apache NMS Active MQ?
Предупреждение NU1701 Пакет "Apache.NMS 1.7.1" был восстановлен с использованием ".NETFramework,Version=v4.6.1" вместо целевой платформы проекта ".NETCoreApp,Version=v2.0". Этот пакет может быть не полностью совместим с вашим проектом.
06 сен '17 в 12:25
1
ответ
ActiveMQ: несколько потребителей подключены к одной очереди, но только один потребитель получает все сообщения
В настоящее время я использую NMS для разработки приложений ActiveMQ(5.6). У нас есть несколько потребителей (exe), пытающихся получить сообщения из одной очереди (не по теме). Хотя все сообщения просто отправляются одному потребителю, я заставляю е…
18 июн '13 в 12:14
1
ответ
Потребительская служба не удаляет все сообщения из очереди ActiveMQ
У меня есть служба Windows, которая пытается использовать сообщения из очереди ActiveMQ. Тем не менее, он получает только некоторые сообщения, а другие застревают в "ожидающих сообщениях" в очереди. ActiveMQ сообщает, что поставил в очередь, скажем,…
17 июн '14 в 21:09
2
ответа
Apache NMS с использованием ActiveMQ: как использовать режим подтверждения транзакций, но при этом каждый раз подтверждать / откатывать одно сообщение?
Я использую Apache NMS (в C#) для получения сообщений от ActiveMQ. Я хочу быть в состоянии подтвердить каждое полученное сообщение или откатить сообщение в случае ошибки. Я решил первую часть с помощью CreateSession(AcknowledgementMode.IndividualAck…
25 фев '19 в 08:33
1
ответ
Почему потребители ActiveMQ восстанавливаются в режиме извлечения вместо предварительной выборки
Недавно я обновил до NMS ActiveMQ 1.5.2, и когда я перезагружаю посредника, соединение и потребители восстанавливаются, но они возвращаются в режим "тянуть", что означает, что посредник не будет отправлять им сообщения автоматически. Это не так, как…
02 дек '11 в 00:24
1
ответ
Подключитесь к RabbitMQ с помощью Apache NMS STOMP
Я пытаюсь читать и записывать сообщения в / из очереди Rabbit MQ (3.6.5) с использованием протокола STOMP. Я использую Apache NMS Stomp (1.5.4) в качестве клиентской библиотеки. При отправке сообщения с использованием NMS я получаю следующее исключе…
12 авг '16 в 11:53
1
ответ
C# Apache.NMS MessageListener OnMessage не запускается
У меня есть следующий код для подключения к серверу ActiveMQ. Соединение работает, потребитель виден в веб-интерфейсе AMQ, в очереди есть сообщения, но OnMessage не выполняется. Я пытался переместить стартовый вызов, но это не помогает. TestConnecti…
02 авг '14 в 14:50
1
ответ
Как позвонить в Apache NMS из песочницы?
Я пытаюсь вызвать Apache ActiveMQ NMS Version 1.6.0 из моего кода ('IntPub'), который должен выполняться в изолированной программной среде в среде.NET 4.0 по соображениям безопасности. Программа, которая создает песочницу, делает мой код "частично д…
16 июл '13 в 10:52
1
ответ
ActiveMQ - сообщения от DurableConsumer не получены
Я пытаюсь почерпнуть сообщения из темы ActiveMQ. В веб-консоли я вижу, что многочисленные сообщения поставлены в очередь в теме, но выполнение следующего кода ничего не возвращает: IConnectionFactory factory = new ConnectionFactory(new Uri("tcp://lo…
12 ноя '13 в 15:23
1
ответ
Apache NMS - как определить, установлено ли соединение
У меня чертовски много времени с некоторыми проблемами Apache NMS. Частично это может быть моим собственным непониманием платформы. По сути, у меня есть клиент NMS STOMP, который я использую для отправки и получения сообщений AMQ через STOMP. API вы…
23 фев '12 в 12:11
2
ответа
Apache NMS в.NET не может подключиться к ActiveMQ [Канал был неактивен слишком долго]
Я пытаюсь подписаться на тему ActiveMQ из приложения.NET, и здесь ниже мой код (я использую Apache NMS 1.7.0): using Apache.NMS; using Apache.NMS.ActiveMQ; ... public void Start() { try { // connect to ActiveMQ long timestamp = DateTime.Now.Ticks / …
11 апр '16 в 18:13
1
ответ
NACK сообщение в Apache NMS
Я пытаюсь использовать Apache NMS Stomp для отправки / получения сообщений. Я не могу использовать режим Transnational Ack из-за использования hornetq. Мой потребительский сценарий: Получить сообщение Обработать сообщение Подтвердите это, если проце…
10 апр '13 в 13:17