Описание тега durable-subscription

0 ответов

Используя js api ActiveMQ, как мне указать подписку на длительную тему?

Я использую ActiveMQ amq.js, чтобы подписаться на темы в моем клиентском js. Я делаю это с помощью вызова, как это: amq.addListener( clientID, "topic://topicName", updateListener ); ... но я бы хотел указать, что подписка на эту тему будет длительно…
1 ответ

Потерянная очередь SYSTEM.MANAGED.DURABLE.* В Websphere MQ

У меня есть очередь 'SYSTEM.MANAGED.DURABLE.ABCD***109', в которой постоянно находятся сообщения, и никто не может их использовать. Я пытался получить его подписку, но получил следующий результат, dis sub(*) where (DEST LK 'SYSTEM.MANAGED.DURABLE.AB…
1 ответ

Как работают постоянные подписчики с JMS?

Таким образом, я создаю одновременных потребителей на тему, то есть несколько слушателей. Я настраиваю их на долговечность. @Bean public DefaultMessageListenerContainer listenerContainers() { DefaultMessageListenerContainer container = new DefaultMe…
1 ответ

Когда долговременные подписки ActiveMQ - плохая идея?

Насколько я понимаю, долговременные подписки при использовании с ActiveMQ позволяют потребителю получать все сообщения, опубликованные в теме, например, если было потеряно соединение, а затем соединение восстанавливается. Сказав это, кажется, что дл…
17 янв '18 в 02:00
1 ответ

JMS Прочная подписка. Абонент не получает сообщения

Изучение длительной подписки. Я подправил пример, приведенный здесь. Я написал две программы. В одном я создаю тему и отправляю сообщение в режиме PERSISTENCE. В другой программе я создаю постоянных подписчиков на одну и ту же тему и пытаюсь получит…
1 ответ

Как я могу справиться с дубликатом длительного абонента Stomp?

У меня есть несколько процессов Ruby, которые запускаются и пытаются подключиться к теме через надежного подписчика с помощью Stomp. Первый процесс завершается успешно и читает сообщения (yay). Последующие процессы завершаются ошибкой, и неоднократн…
1 ответ

Многократная долговременная подписка JMS на одну тему

Я начал JMS в течение недели. Я создал JMS, используя Netbeans, Maven и Glassfish. У меня есть один производитель и один потребитель длительного пользования, и я хотел добавить еще одного потребителя длительного пользования в ту же тему(не в очередь…
19 сен '14 в 02:36
1 ответ

Использование надежных подписчиков с виртуальными темами в ActiveMQ и играет ли политика восстановления подписки какую-либо роль?

Я немного запутался здесь о том, как правильно использовать ActiveMQ. Что я пытаюсь сделать У меня есть система А, которая выдает сообщения на виртуальную тему. Затем есть системы B и C, которые оба принимают сообщения из одной и той же виртуальной …
2 ответа

ActiveMQ - клиент уже подключен с той же ошибкой clientId

У нас есть настройка JBoss EAP 7.0.0.GA для подключения к ActivMQ apache-activemq-5.14.3. Мы пытаемся настроить надежного абонента со следующей конфигурацией: @MessageDriven( name = "TestListener", activationConfig = { @ActivationConfigProperty(prop…
0 ответов

Как однозначно идентифицировать слушателя сообщения в методе OnMessage

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

Как получить список клиентов с длительной подпиской / подписчиком / потребителем из раздела ActiveMQ

Мы используем ActiveMQ в качестве брокера MQTT с долгосрочной подпиской. Когда клиент подписывается на topic с durable mode, есть active durable topic subscribers будет обнаружен на консоли ActiveMQ, как показано ниже. Тем не менее, мы можем получит…
0 ответов

Как удалить постоянных подписчиков на тему в ActiveMQ?

Мой JMS Config указан ниже. Как я могу отписаться от постоянного абонента? На основе значения, указанного в файле env.properties, я создаю N постоянных подписчиков. Этот код ниже является конфигурацией для создания и запуска брокера. Также есть конф…
0 ответов

Исправление места назначения темы в IBM MQ (с использованием WebSphere Application Server 8.5.5)

У меня есть приложение, работающее в WAS 8.5.5, которое использует sub sub с IBM MQ и постоянных подписчиков. На клиентском сайте мы видим периодически возникающие проблемы при повторном открытии подписок на тему при запуске сервера. Когда я смотрю …
1 ответ

Прочная подписка ActiveMQ

Я пытаюсь установить надежного подписчика для своих сообщений, чтобы они сохранялись в теме даже после перезапуска сервера. Но во время настройки я получаю ошибку, связанную с XML: Вот моя конфигурация xml: <?xml version="1.0" encoding="UTF-8"?&g…
1 ответ

Spring - ActiveMQ - Durable Subscription - закрытие соединения и повторная подписка для получения автономных сообщений

Я хочу реализовать решение в Spring-JMS с ActiveMQ, где я хочу создать долговременную подписку на тему. Цель состоит в том, что если подписчик на некоторое время закрывает подписку и снова создает подписку длительного пользования с тем же идентифика…
2 ответа

Отписаться от постоянных подписчиков с ActiveMQ

Я пытаюсь НЕ ПОДПИСАТЬ постоянных подписчиков на ТЕМЫ. Мое приложение - это своего рода социальная сеть: каждый пользователь - это тема для других пользователей. Таким образом, каждый раз, когда пользователь что-то делает, его друзья получают уведом…
1 ответ

Запрос относительно Spring-Driven-Channel-Adapter

Я использую управляемый сообщениями-канал-адаптер Spring. Мой компонент потребляет сообщение от темы Tibco и публикации в тему RabbitMQ Итак, поток сообщений выглядит следующим образом: Tibco-> (подписанный) Компонент (Опубликовано)-> RabbitMQ Актив…
0 ответов

Spring 5 динамическая JMS долговременная подписка

У меня есть вопрос, касающийся создания динамических долговременных подписок JMS и, в более общем плане, о том, как справляться с динамическими ситуациями в Spring 5 и SpringBoot. Например, чтобы сделать долговременную подписку, необходимо следующее…
10 апр '18 в 11:51
1 ответ

Реализация долговременной подписки на ServiceMix

В настоящее время я использую ServiceMix для маршрутизации сообщений с использованием библиотек QPID. Мой рабочий конфиг ниже: <?xml version="1.0" encoding="UTF-8"?> <blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0" xmlns:xsi="h…
1 ответ

JBoss AMQ / ActiveMQ Artemis: предварительная настройка надежных подписчиков

У меня есть брокер Red Hat AMQ (основанный на ActiveMQ Artemis), и я хотел бы использовать функцию долговременной подписки (или эквивалентную), чтобы у меня было несколько подписчиков OpenWire JMS, подписывающихся на события нашего приложения, котор…
23 ноя '18 в 07:33