0
голосов
1отвечать
60 просмотров

Приложение-потребитель IBMMQ не может использовать TextMessage (JMSCMQ1049: набор символов '1208 (UTF-8) Unmappable Action: REPORT)

У меня есть потребительское приложение, которое использует IBMMQ для получения сообщений от администратора очередей. Я не контролирую издателя, только потребителя. Вот часть кода для моего потребителя: while (...
0
голосов
1отвечать
30 просмотров

Как я могу измерить время ответа (обработки) SuT с помощью модели обмена сообщениями JMS Point-to-Point через IBM MQ?

У меня есть удаленный экземпляр IBM MQ с двумя очередями. За ними стоит Тестируемая Система, которая всегда принимает сообщения, помещенные в INBOUND.QUEUE "выполняет некоторую обработку и отправляет ответ ...
0
голосов
1отвечать
29 просмотров

Как можно использовать JMS Point-to-Point Sampler в Jmeter для отправки сообщений в очередь IBM MQ

У меня есть локальный экземпляр IBM MQ, настроенный с некоторыми очередями по умолчанию. Используя JMeter 5.4.1, я сначала хочу отправить сообщения в одну из этих очередей, чтобы проверить, работает ли соединение. 1. Возможно ли с IBM ...
0
голосов
1отвечать
26 просмотров

JMS: имеет ли смысл иметь производителя и связанного с ним потребителя в одном приложении?

Я новичок в JMS и хотел бы знать, имеет ли смысл иметь производителя и связанного с ним потребителя в одном приложении? Если да, то каковы, например, случаи?
0
голосов
1отвечать
27 просмотров

Есть ли способ автоматической повторной подписки, когда подписчик выходит из строя или перестает получать сообщение из темы в activeMQ с помощью JMS? [закрыто]

Есть ли способ автоматической повторной подписки, когда подписчик не работает или перестает получать сообщение из темы в ActiveMQ с помощью JMS? На самом деле мой один из подписчиков исчезает (проверено с activeMQ ...
-1
голосов
0ответы
16 просмотров

mkahaDb в activemq при большом количестве очередей [закрыто]

Можем ли мы использовать MKahadb с perDestination для брокера activeMq, у которого 6000+ очередей? Будет создано 6000 каталогов и у каждого будет собственный индексный файл db.data? Замедлит ли это восстановление системы? Жестяная банка ...
-2
голосов
0ответы
27 просмотров

Адаптер ActiveMQ mkahadb

У меня более 5000 клиентов, которые хотят подключиться к брокеру. У каждого есть отдельная очередь. Некоторые из них могут отключаться и повторно подключаться, в то время как их данные могут засасывать файл журнала, что предотвращает ...
-1
голосов
1отвечать
27 просмотров

Какой пакет KahaDB или существующий JDBC для activeMQ?

Я хочу разработать кластер ActiveMQ, способный иметь 6000 активных потребителей в каждом. Я собираюсь использовать NIO для транспорта, чтобы объединить соединение в соединение с брокером. На уровне хранения у меня проблема. ...
-1
голосов
1отвечать
40 просмотров

Как сообщения читаются из ActiveMQ и доставляются в соответствующую очередь?

Я хочу, чтобы очереди получали данные от брокера activemq (kahaDB), который хранит данные в виде скользящего журнала. Нет журнала для конкретной очереди. Все сообщения из разных очередей будут храниться в одном журнале ...
-1
голосов
2ответы
45 просмотров

Транспортный соединитель ActiveMQ Java NIO против PoolConnectionFactory

Каковы различные варианты использования транспортного коннектора Java NIO и PoolConnectionFactory в ActiveMQ. Оба обслуживают пул подключений. Я хочу, чтобы тысячи клиентов подключались к брокеру и ...
1
голосование
1отвечать
91 просмотр
+50

Загрузочные приложения Spring с JMS (ActiveMQ) поверх docker-compose: java.net.BindException: невозможно назначить запрошенный адрес (сбой привязки)

Имею два весенних загрузочных приложения. Я хочу использовать JMS для отправки сообщения из одного приложения в другое. Это приложение работает поверх docker-compose. В клиентском приложении это: @EnableJms @Configuration public class ...
0
голосов
1отвечать
25 просмотров

Снижение производительности в ActiveMQ Artemis после пейджинга

После того, как брокер перешел в режим подкачки, я наблюдаю странное падение производительности. Некоторые сообщения начали занимать очень много времени: 1800мс 10мс 15мс 700мс Я также вижу много использования диска: My ...
0
голосов
0ответы
15 просмотров

Микроинтегратор wso2 <-> интеграция activemq

Я пытаюсь создать прокси-сервис между ActiveMQ и WSO2 через IntegrationStudio 8.0. Я столкнулся с проблемой. Вот код моей прокси-службы: <? Xml version = "1.0" encoding = "...
0
голосов
1отвечать
28 просмотров

Mule 4 - Как установить идентификатор сеанса для коннектора JMS

У меня есть требование, в котором мне нужно использовать очередь служебной шины Azure, которая соответствует шаблону FIFO в Mule 4. В соответствии с требованием я использую JMS Connector вместо Microsoft ASB Connector. В очереди ASB есть ...
0
голосов
2ответы
44 просмотра

Пакетный потребитель ActiveMQ

У меня есть требование потреблять сообщения из темы ActiveMQ и сохранять их в монго. Мне интересно, есть ли способ / конфигурация для пакетного использования сообщений из темы ...