Публикации по теме 'activemq'


Запустите локальный экземпляр ActiveMQ в Docker.
Apache ActiveMQ — это брокер сообщений с открытым исходным кодом, написанный на Java, который предлагает кластер высокой доступности, обеспечивающий балансировку нагрузки и поддержку отказоустойчивости для ваших приложений, управляемых сообщениями. Он поддерживает различные межъязыковые клиенты и протоколы, включая Java, C, C++, C#, Ruby, Perl, Python и PHP. Использование Docker для запуска ActiveMQ имеет несколько преимуществ. Он позволяет легко упаковать брокера ActiveMQ в контейнер,..

Использование ActiveMQ с Node.js, STOMP и HTTP
ActiveMQ написан на Java и имеет полноценный JMS-клиент, но его поддержка STOMP и RESTful API позволяют нам легко взаимодействовать с очередью сообщений с помощью Node.js. С Node вы обнаружите, что STOMP - отличный выбор протокола для подписки на очереди, в то время как HTTP идеально подходит для отправки сообщений (и особенно хорош для сообщений, которые должны быть доставлены в установленное время из-за большого количества информации. ответ, который мы получаем из очереди при..

Создайте образ Docker для ActiveMQ 5.x с сохранением PostgreSQL
Создайте образ Docker для ActiveMQ 5.x с сохранением PostgreSQL В этом посте мы создадим собственный образ Docker для версии ActiveMQ 5.x вместе с базой данных PostgreSQL для сохранения сообщений. Если вам нужна технология очередей для поддержки архитектуры микросервисов или для асинхронного выполнения задач, ActiveMQ поможет вам. Я использовал ActiveMQ в различных проектах, и это мое решение в топе, когда мне нужна интеграция quick и easy . В конце концов, он делает то, что..

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

Событие получения сообщения ActiveMQ Только одно сообщение в секунду?
Мы создали инфраструктуру приложений на основе ActiveMQ. Мы можем отправлять и получать сообщения просто отлично, и по большей части все работает довольно быстро и нормально. Тем не менее, мы заметили, что если мы отправим пакет сообщений «за...
1321 просмотров
schedule 02.08.2023

Как я могу запустить сайт ajax push (activemq, cometd или что-то еще)?
Я хочу запустить приложение, которое будет использовать ajax push, однако веб-сервер должен быть правильно настроен, и я не знаю, как запускать компоненты на стороне сервера. Я хотел начать с dojo's cometd , а затем прочитать несколько блогов, в...
2045 просмотров
schedule 21.04.2023

Как ограничить доступ к JMX API ActiveMQ только для локального хоста/интрасета?
Я только начал использовать JMX для мониторинга activemq, я включил удаленный мониторинг. Теперь вопрос: как разрешить только локальному хосту доступ к JMX API? Или есть способ использовать JMX API без включения удаленного мониторинга.
2511 просмотров
schedule 03.05.2023

Использование Log4J JMSAppender с ActiveMQ
Я пытаюсь создать доказательство ведения журнала доставки концепции из Log4J через JMS с использованием log4J JMSAppender. Я пробовал ActiveMQ и прилагаемый к нему пример. Я разобрал этот пример на части и сделал его более общим и совместимым с...
8973 просмотров
schedule 28.08.2023

Как заставить локального брокера ActiveMQ отразить очередь на удаленном брокере ActiveMQ?
У меня есть локальный брокер ActiveMQ с ненадежным подключением к Интернету, а также удаленный брокер ActiveMQ в надежном центре обработки данных. Я уже разобрался с настройкой «хранить и пересылать», чтобы исходящие сообщения отправлялись удаленному...
5013 просмотров
schedule 04.10.2022

Написание JMS Publisher без public static void main
Каждый пример, который я видел в Интернете, например. http://www.codeproject.com/KB/docview/jms_to_jms_bridge_activem.aspx , создает издателя и подписчика с помощью метода public static void main . Я не думаю, что это сработает для моего...
666 просмотров
schedule 10.06.2022

Создание очередей JMS во время выполнения
Я работаю над приложением, в котором пользователь приложения может создавать/удалять очереди. Также он сможет переместить сообщение из 1 очереди в другую, удалить сообщение, переставить сообщения в очереди на основе некоторого фильтра. Одним из...
6771 просмотров
schedule 04.08.2022

Дизайн схемы MongoDB - чат в реальном времени
Я начинаю проект, который, как мне кажется, будет особенно подходить для MongoDB из-за скорости и масштабируемости, которые он предоставляет. Модуль, который меня сейчас интересует, связан с чатом в реальном времени. Если бы мне пришлось делать...
13453 просмотров

активный обмен сообщениями с помощью stomp и activemq.prefetchSize=1
У меня есть ситуация, когда у меня есть один брокер activemq с двумя очередями, Q1 и Q2. У меня есть два потребителя на основе ruby, использующие активный обмен сообщениями. Назовем их С1 и С2. Оба потребителя подписываются на каждую очередь. Я...
1850 просмотров
schedule 14.05.2023

ActiveMQ: очередь недоставленных сообщений сохраняет порядок моих сообщений
Я использую ActiveMQ в качестве брокера для доставки сообщений. Эти сообщения предназначены для написания в dabatase. Иногда база данных недоступна или недоступна. В этом случае я хочу откатить свое сообщение, чтобы повторить попытку позже, и я...
6242 просмотров
schedule 07.06.2024

ReceiveNoWait не работает с Apache.NMS и ActiveMQ
Я столкнулся с проблемой при использовании ReceiveNoWait с Apache.NMS и ActiveMQ, очень простые сценарии: private static void Send(string text) { var factory = new ConnectionFactory("tcp://localhost:61616/"); using (var connection =...
1172 просмотров
schedule 09.01.2023

Настройте очередь JMS (ActiveMQ), чтобы она содержала только последнее сообщение.
У нас есть кварцевый процесс, который опрашивает очередь ActiveMQ JMS. Мы знаем, что можем получать несколько сообщений в минуту, но хотели бы отвечать только на самое последнее сообщение с настроенной частотой опроса в минуту или более. Нам не...
1343 просмотров
schedule 27.07.2022

Проблемы с использованием genericra для интеграции activemq и glassfish при использовании протокола аварийного переключения
Я пытаюсь использовать activemq в Glassfish, используя адаптер ресурсов genericra, поставляемый с Glassfish 2.1. Я нашел несколько страниц с полезной информацией, включая http://activemq.apache.org/sjsas-with-genericjmsra.html . На самом деле я...
1341 просмотров

Дублированные сообщения в ActiveMQ
Я использую ActiveMQ в качестве брокера и потребителя JMS, jmsTemplate для отправки сообщений, 1 недолговечную тему на данный момент. В пиковое время у меня ~ 100 сообщений в секунду. Неважно, сколько сообщений в очереди, но я часто получаю...
6197 просмотров
schedule 08.04.2022

Протокол STOMP — вопросы об идентификаторе сеанса
Из описания протокола STOMP 1.0 (http://stomp.github.com/stomp-specification-1.0.html) (выделено мной): После того, как клиент отправит кадр CONNECT, сервер всегда будет подтверждать подключение , отправляя кадр, который выглядит следующим...
1117 просмотров
schedule 23.10.2022

c ++ ActiveMQ отправка двоичных сообщений
Можно ли отправить поток строк, содержащий двоичный файл, поверх activemq? Если да, то как это делается? Я знаю, что Java-версия activemq имеет для этого функцию BlobMessage или StreamMessage, однако она еще не реализована в версии для C ++. Я...
1550 просмотров
schedule 07.11.2022

Проблема со скриптами Apache Camel
У меня очень странная проблема с Apache ActiveMQ с Camel - я попробовал примеры с javascript и groovy, но они оба выдают ошибку "Не удалось установить маршрут: не удалось создать маршрут... из-за того, что не удалось найти язык для: groovy"...
3475 просмотров

ActiveMQ отправляет и получает папку файла XML
У меня есть java-приложение, которое выполняет ввод-вывод файлов: Модуль 1: выходной текстовый файл (жесткий диск). Модуль 2: входной файл txt (HD) выход: папка файлов XML (HD) Я хочу извлечь выгоду из ActiveMQ Модуль 1 -> вывод (отправка)...
1580 просмотров
schedule 28.07.2022

Проблема с несколькими потребителями в activeMQ
У нас есть два экземпляра activemq, настроенные как кластер, и кластер из четырех экземпляров glassfish, которые должны быть подключены к ОДНОМ activemq в любой момент времени. Если activemq01 недоступен, все четыре экземпляра glassfish должны...
1099 просмотров
schedule 04.04.2023

Как настроить очередь недоставленных сообщений для каждой устойчивой темы?
Я настроил приложение для прослушивания темы ActiveMQ. Вот как я его настроил: <jms:listener-container connection-factory="jmsFactory" container-type="default" destination-type="durableTopic" client-id="CMY-LISTENER"...
1442 просмотров
schedule 20.06.2023