Вопросы по теме 'jms-topic'
Правильное использование связи JMS-Topic
Я хочу использовать JMS (Topic) в моем проекте JavaEE 6. У меня есть один класс, который действует как издатель и подписчик темы одновременно. В следующем коде показаны наиболее важные части класса.
public class MessageHandler implements...
457 просмотров
schedule
13.05.2023
Тема ActiveMQ JMS - удаление старых сообщений
Есть ли способ отслеживать сообщения в теме ActiveMQ JMS и, самое главное, удалять старые сообщения, например удалять сообщения старше месяца назад.
Я использую Apache Camel для создания тем ActiveMQ Connection и JMS.
5769 просмотров
schedule
17.03.2022
Как поддерживаются подписчики в случае распределенного обмена сообщениями на основе темы
У меня есть следующие два вопроса, связанные с распределенной системой обмена сообщениями.
Чем тема отличается от очереди?
Как поддерживаются подписчики в случае с темами.
Пожалуйста, поделитесь любым документом или ссылкой, которые могут...
144 просмотров
schedule
27.10.2022
JMS — Использование тем в WebSphere Application Server 7
У меня есть отправитель и получатель для определенной темы. Я запускаю отправителя и получателя как сервлеты на WAS 7.0. Topic и Topic Connection Factory настраиваются на WAS. Но я не могу получить сообщение, которое отправляется. Он отлично...
177 просмотров
schedule
23.04.2023
долговечная и не долговечная разница JMS-Topic. Какой лучше использовать прочный или недолговечный?
Может ли кто-нибудь четко объяснить, что является прочным и недолговечным в теме JMS?
У меня есть модель сервера и клиента, до сих пор сервер будет отправлять запрос клиенту, чтобы завершить запрос, отправленный с сервера, и клиент принимает запрос...
4218 просмотров
schedule
26.06.2022
Подключение MQTT к ActiveMQ TOPIC занимает много времени в приемнике событий WSO2 CEP
Обновить
В исходном коде MQTTAdapterListener проекта carbon-analytics-common как это ссылка
run() будет спать поток, и я считаю, что это причина того, что соединение MQTT займет так много времени.
@Override
public void run() {...
229 просмотров
schedule
08.05.2022
Как подписаться на тему в WSO2 MB 3.1.0
Я некоторое время работал с WSO2 Message Broker и четко понял, как публиковать и использовать сообщения в очереди и из тем, а также в темах. Согласно этому , нигде не упоминалось, как могу ли я подписаться на конкретную тему из консоли...
88 просмотров
schedule
29.11.2022
Селекторы сообщений и темы для фильтрации сообщений в Tibco EMS
Я работаю над клиент-серверным приложением, используя темы Tibco EMS для связи Pub/Sub.
В одном из наших вариантов использования нам нужно отправлять несколько миллионов сообщений в минуту, разделенных на >200 000 "тем" .
Каждому клиенту...
993 просмотров
schedule
18.01.2023
Создайте автономный клиент JMS с помощью JAVA.
Я новичок в JMS, и мне нужно создать универсальный клиент JMS, чтобы создать соединение для отправки и получения сообщения с использованием очередей и тем. Я видел много примеров использования фабрики соединений ActiveMQ, но мне нужен универсальный...
210 просмотров
schedule
23.10.2022
Тема ActiveMQ отправляется автоматически
У меня есть несколько подписчиков, которые слушают "mytopic"... Я отправляю им сообщение через пользовательский интерфейс браузера, как прикрепленное изображение, но теперь я хочу выполнить эту работу в среде кода, что мне делать, и что это за код и...
102 просмотров
schedule
11.05.2023
Метод JMS CachingConnectionFactory onException никогда не вызывается для JMSException
Я использую Apache Camel с Spring для отправки сообщений из моей службы Java. Мне нужно сбросить соединение JMS в случае какой-либо ошибки при обмене. Я использую приведенный ниже код для достижения своей цели.
try
{...
870 просмотров
schedule
10.05.2023
Сколько сообщений может содержать тема activemq с несколькими постоянными подписчиками?
У меня есть несколько постоянных подписчиков, подписанных на тему? Сколько сообщений может вместить тема? Какое максимальное количество сообщений он может хранить?
Я использую KahaDB в качестве адаптера сохранения. Я предполагаю, что это зависит...
171 просмотров
schedule
29.06.2022
Тема ActiveMQ — сообщения не сохраняются в базе данных
Я включил постоянство в брокере ActiveMQ. Он сохраняет сообщения в таблице БД для сообщений в очереди. Проблема ActiveMQ не сохраняет сообщения в базе данных для ТЕМ. Конфигурация прикреплена ниже. Я ищу сообщения в таблице activemq_msgs ....
1118 просмотров
schedule
22.01.2023
Задержка повторной доставки JMS, такая как число Фибоначчи
Я хотел бы установить политику повторной доставки, например число Фибоначчи, в теме jms. например, повторная доставка, как показано ниже:
1 1 2 3 5 8 13 21 34 55 89 144 ...
Есть ли стандартный конфиг на jms для этого?
50 просмотров
schedule
30.11.2022
Вопросы по JMS Pub / Sub
Я новичок в JMS pub / sub, использую Spring boot и Apache Active MQ. Не могли бы вы помочь разобраться в приведенных ниже сценариях?
Сценарий 1:
Шаг 1. У меня есть издатель, который публикует сообщение (Say MessageA) в теме (Say TopicA), и в то...
45 просмотров
schedule
20.04.2022
Будет ли этот Camel Route подтверждать сообщение в сценарии исключения?
У меня есть маршрут Camel, который преобразует JSON в объект и передает его классу процессора. Код ниже. Этот потребитель ActiveMQ не подтверждает некоторые сообщения, что приводит к резервному копированию раздела. Код явно не устанавливает режим...
736 просмотров
schedule
24.04.2024
Подписчик темы не получил сообщение
Недавно работаю с Topic в jms и у меня возникла проблема. Мой TopicSubscriber не получил сообщение от издателя, и я не понимаю, почему.
Вот мой TopicPublisher:
public class Publisher
{
private static final String CONNECTION_URL =...
169 просмотров
schedule
20.01.2023
Как получить текущее количество сообщений в теме jms на IBM WAS
Мне нужно создать службу REST на языке программирования Java, которая получает имя JNDI фабрики соединений JMS и имя JNDI темы JMS в качестве входных данных и должна возвращать количество сообщений в ресурсе на данный момент. Проблема заключается в...
210 просмотров
schedule
31.05.2022
Подписка и чтение из темы: ActiveMQ и Python
Я пытаюсь подписаться на тему в ActiveMQ, запущенную в localhost , используя stompest для подключения к брокеру. Пожалуйста, обратитесь к коду ниже:
import os
import json
from stompest.sync import Stomp
from stompest.config import StompConfig...
378 просмотров
schedule
14.03.2023
