Вопросы по теме 'broker'

Невозможно настроить компонент-брокер для ActiveMQ
У меня возникли проблемы с настройкой брокера ActiveMQ через внешний XML-файл, проанализированный xBean. На этом этапе приветствуется ЛЮБАЯ помощь, подсказки, подсказки или даже подбадривание. Вот моя проблема: Я пытаюсь использовать внешний...
2923 просмотров

Ограничения механизма SunRPC как архитектуры клиент-диспетчер-сервер и сравнение с брокером
Я читаю книгу по шаблонам проектирования (старое издание) " Архитектура программного обеспечения, ориентированная на шаблоны ". В главе, посвященной клиент-диспетчеру-серверу, SunRPC упоминается как архитектура клиент-диспетчер-сервер, при этом...
711 просмотров

Модифицированный брокер ActiveMQ
Я хочу написать модифицированный брокер ActiveMQ, который, когда он прослушивает сообщения производителей определенной темы, обрабатывает их альтернативно (например, использует API HDFS и не использует постоянное хранилище по умолчанию). У вас есть...
257 просмотров
schedule 29.04.2024

Статическая сеть брокера activemq перестает пересылать сообщения без включения AdvisorySupport?
Я настроил сеть брокеров в соответствии с этот пост Брюса Снайдера: Брокер 1: <networkConnector name="amq1-nc" uri="static:(tcp://localhost:61617)" userName="system" password="manager" />...
2279 просмотров
schedule 29.03.2023

Отказоустойчивый протокол Apache ActiveMQ
Почему только java может обеспечить поддержку протокола аварийного переключения в activemq, а не в других языках. Я сомневаюсь, что в протоколе отработки отказа, таком как failover://(tcp://host1:61616,tcp://host2:61616)?randomize=false , клиент...
1450 просмотров

Как работает распространение подписки на виртуальную тему Activemq в сети брокеров?
Может ли кто-нибудь прояснить поведение виртуальных тем activemq в контексте Сети брокеров? У меня путаница по поводу распространения подписки. Например, у одного брокера есть сетевой соединитель с другим. Допустим, у брокера mq001 есть следующий...
2325 просмотров
schedule 17.06.2023

Поддержка веб-сокетов Mosquitto 1.4.2
Я пытаюсь использовать последнее обновление Mosquittos для поддержки веб-сокетов в брокере. Я использую Mosquitto v1.4.2 и добавил следующие строки в файл конфигурации mosquitto (mosquitto.conf): listener 10001 127.0.0.1 protocol websockets...
10740 просмотров
schedule 21.06.2023

Простое клиент-серверное приложение UDP NodeJS с использованием брокера
Я пишу простое клиент-серверное приложение NodeJS, использующее протокол UDP. Суть этого приложения в том, что оно требует использования брокера, функция которого в данном случае состоит в том, чтобы связать отправителя с получателем. Требования...
304 просмотров
schedule 13.07.2022

Использование Office Interop в приложении Магазина Windows 8.1
Я работаю над приложением для создания заметок в Windows 8.1 для клиента. Приложение должно будет использовать библиотеку OneNote для взаимодействия с офисом, чтобы сохранять и открывать файлы OneNote. Я не могу использовать REST API для OneNote,...
326 просмотров
schedule 09.04.2023

Брокер Mqtt, закрытие старого соединения
Клиент mqtt имеет тот же идентификатор клиента. Как закрыть старое соединение? именно так. New connection from 192.168.3.57 on port 1883. 1479826181: Client paho166768969170988 already connected, closing old connection. 1479826181: Client...
2816 просмотров
schedule 27.03.2023

Запуск Celery в качестве демона не будет использовать брокера Redis
у меня есть celery==3.1.23 Django==1.9.1 redis==2.10.5 ii redis-server 2:2.8.19-3 amd64 Persistent key-value database with networ ii redis-tools 2:2.8.19-3 amd64 Persistent key-value database with networ...
1114 просмотров
schedule 10.04.2024

Конфигурация Erlang MQTT сломана?
Есть способ (согласно этому и this ) в Erlang eMQ, чтобы включить в моем MQTT Broker плагин для emq_auth_username , что означает, что я могу настроить своего брокера так, чтобы он разрешал подключения на основе моего файла...
93 просмотров
schedule 14.01.2024

Запуск ActiveMQ программно, а не как служба
Я работаю с ActiveMQ и создаю производителя и потребителя для некоторых сообщений. Таким образом я создаю соединение и создаю место назначения: ActiveMQConnectionFactory factory = new...
1593 просмотров
schedule 03.11.2022

Как решить проблему org.eclipse.paho.client.mqttv3.internal.ClientState.checkForActivity клиента mqtt?
Я написал клиент mqtt на java для брокера mosquitto. он работает некоторое время, но через некоторое время, если нет трафика между моим клиентом и брокером mqtt, он отключается со следующей ошибкой: Как мне оставаться на связи с брокером mqtt...
1109 просмотров
schedule 02.05.2023

Соответствующие настройки для регистрации информации о брокере / порте для Kafka Cluster
Я прочитал следующее из confluence wiki для kafka , и я цитирую его ниже: Почему я вижу ошибку «Не следует устанавливать смещение конца журнала для раздела» в журнале брокера? Как правило, вы увидите следующие ошибки....
1914 просмотров
schedule 26.03.2022

Каков вариант использования BrokerService в ActiveMQ и как его правильно использовать
Я новичок в ActiveMQ. Я пытаюсь изучить и проверить, как это работает, проверив пример кода, предоставленный Apache по этой ссылке: - http://activemq.apache.org/how-should-i-implement-request-response-with-jms.html public class Server...
1424 просмотров
schedule 30.06.2022

Пакт для MessageQueue: образец теста провайдера в случае MessageQueues
Я написал образец теста Pact для MessageProvider, обратившись к образцу примера, приведенному в репозитории pact. Ниже приведен тест потребителя, который генерирует файл PACT json для сообщения, ожидаемого от поставщика. В случае API, чтобы...
2670 просмотров
schedule 09.09.2022

Node.Js MQTT-брокер
У меня есть следующий код в node.js. Он отлично подключается к брокеру, который я установил на своем личном веб-сайте/сервере, и может отправлять и прослушивать события с server.js. Моя проблема в том, что он не прослушивает другие события,...
6347 просмотров
schedule 08.02.2023

Интеграция безопасности в Kafka 1.0 с включенным SSL
Я не могу интегрировать безопасность в Kafka 1.0 с включенным ssl. Вот изменения в моем server.properties security.inter.broker.protocol=SSL listeners=PLAINTEXT://localhost:9092,SSL://localhost:9094 Вот мои рекламируемые слушатели...
1973 просмотров
schedule 15.12.2023

Используйте Confluent CLI для запуска нескольких брокеров kafka
Мне не удалось найти ответ на этот вопрос, и я столкнулся с некоторыми трудностями при попытке его реализовать. Может ли команда confluent только запускать несколько брокеров + Zookeeper? Можно ли построить кластер kafka, состоящий из 3 узлов, с...
146 просмотров