Описание тега activemq-classic

Apache ActiveMQ - это брокер сообщений с открытым исходным кодом (с лицензией Apache 2.0), который полностью реализует Java Message Service 1.1 (JMS). Он предоставляет "корпоративные функции", такие как кластеризация, несколько хранилищ сообщений и возможность использовать любую базу данных в качестве поставщика сохраняемости JMS, помимо ВМ, кеширования и сохраняемости журнала.
3 ответа

Веб-сервис отдыха Джерси с интеграцией промежуточного программного обеспечения Activemq

У меня есть API сервиса Restful, разработанный с использованием JAX-RS и трикотажа. Я развернул то же самое в TOMCAT 7. Теперь я хотел бы реализовать Activemq, чтобы хранить все запросы в очереди и обрабатывать ресурс запроса. Как это сделать и инте…
31 окт '13 в 12:39
0 ответов

Потребитель ActiveMQ не может удалить сообщение из очереди

Я использую реализацию JMS-очереди Apache ActiveMQ, в которой около 300 потребителей прослушивают отдельные очереди в одном экземпляре AMQ, размещенном за конфигурацией nio-ssql.потребитель 1 слушает Queue1потребитель 2 слушает Queue2потребитель 3 с…
25 окт '17 в 15:18
2 ответа

Верблюжий маршрут "до" определенной конечной точки веб-сокета

У меня есть несколько верблюжьих маршрутов с розетками мины и пристанью. Я могу передать сообщение всем клиентам, подключенным к веб-сокету, но как мне отправить сообщение определенной конечной точке. Как мне вести список всех подключенных клиентов …
09 май '13 в 17:25
1 ответ

Настройка ActiveMQ Objectmessage, сериализуемого из Scala

После изменения версии ActiveMQ (с 5.9.0 r4 на r4) необходимо пометить ObjectMessage ActiveMQ сериализуется явно, как написано здесь: http://activemq.apache.org/objectmessage.html. Установка переменной среды как предложено (-Dorg.apache.activemq.SER…
26 апр '16 в 13:14
0 ответов

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

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

Пространство кучи Java, когда пространство действительно доступно

Я пытаюсь отправить BytesMessage на AMQ (5.15.2), но я запускаю в исключении кучи, даже если память явно доступна. Здесь byte[] contcentBuilder = new Byte[1000*1000*1]; Array.fill(contentBuilder, (byte) 1); BytesMessage message = session.createBytes…
08 фев '18 в 11:52
2 ответа

Как delpoy приложение Mule, когда Teradata, Oracle DB не работает

Если БД или ActiveMQ, Teradata не работает, развертывание службы не происходит. Но код / ​​сервис должны быть развернуты, даже если БД не работает. Пожалуйста, помогите внести соответствующие изменения в код для этого, чтобы развернуть код.
17 фев '15 в 07:31
2 ответа

Не может использовать сообщение ActiveMQ на tomcat

Я пытаюсь настроить Apache Active MQ в Apache Tomcat. У меня есть два файла war, MessageProducer.war и MessageConsumer.war. Я добавил все банки зависимостей ActiveMQ в папку /WebContent/WEB-INF/lib обоих проектов. Я добавил следующие ресурсы, настро…
06 окт '16 в 09:51
2 ответа

activemq запрещает удаленные подключения

Я пытаюсь запустить ActiveMQ с Maven, используя следующую команду mvn org.apache.activemq.tooling:maven-activemq-plugin:5.7.0:run Это работает локально, но блокирует удаленные соединения. Как я могу заставить ActiveMQ принимать удаленные подключения?
22 июн '13 в 11:09
1 ответ

Ненормальное поведение Apache ActiveMQ на нескольких потребителях

Я использую Jboss-fuse-6.3, с внешним Apache-activemq-5.15.2. Я связал 50 потребителей в очереди, и на портале Active MQ на странице "Активные потребители" я заметил, что все 50 потребителей связаны, но распределение сообщений в очередях не одинаков…
19 дек '17 в 11:21
0 ответов

Почему я не могу отправлять сообщения в ActiveMQ с WSO2 EI 6.0.0?

Я перешел по ссылке ESB в качестве производителя JMS для настройки отправителя и получателя. Я также разместил следующие jars activemq-broker-5.8.0.jar activemq-client-5.8.0.jar activemq-kahadb-store-5.8.0.jar geronimo-jms_1.1_spec-1.1.1.jar geronim…
24 мар '17 в 21:32
3 ответа

В кластере ActiveMQ, как найти потребителя, который выбрал конкретное сообщение или набор сообщений?

У нас есть набор очередей, и маршруты верблюдов были написаны для приема сообщений из очереди - очереди живут на сервере ActiveMQ, а маршруты верблюдов - в Apache Karaf. Мы создали кластер с несколькими узлами karaf; проблема в том, что эти сообщени…
09 июн '15 в 14:09
1 ответ

Отложенная доставка JMS на основе условных переменных

Я ищу возможность в любой из наиболее популярных очередей сообщений (AMPQ, RabbitMQ, ActiveMQ и т. Д.) Условно задержать доставку сообщения. Например: System A sends a message(foo, condition = bar.x > 1); System B sends a message(bar, x = 2) Поск…
05 авг '15 в 09:12
1 ответ

Поглотить сообщение из очереди jms

Как использовать сообщения, помещенные в "jmsQueueConsumer:queue:consumer.queue" в следующем коде: CamelContext context1 = new DefaultCamelContext(); ConnectionFactory connectionFactory1 = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_BRO…
18 сен '13 в 11:51
1 ответ

Не удается увидеть тело сообщения в activeMq, когда сообщение отправлено через wso2 esb

Я новичок в этом. Я создал хранилище сообщений jms в wso2 esb и отправил ему сообщение. Сообщение было получено в activeMq, но не может видеть тело сообщения в Activemq. Подробности сообщения: org.apache.synapse.message.store.impl.commons.StorableMe…
25 июл '16 в 23:08
1 ответ

InstanceNotFoundException при попытке обнаружить очереди в JMS Hermes

У меня есть активный MQ и Гермес JMS. Разъем JMX для активного mq включен в activemq.xml: <managementContext> <managementContext createConnector="true"/> </managementContext> Но когда я пытаюсь обнаружить очереди в активной сессии …
26 мар '14 в 08:04
4 ответа

Есть ли очередь поддержки MQTT в ActiveMQ?

Я новичок в этом и узнаю об этом протоколе. Пока читал в вики про MQTT. первая строка "MQTT[1] - это протокол обмена сообщениями" облегченный ", основанный на публикации и подписке, для использования поверх протокола TCP/IP". Значит ли это, что MQTT…
03 июл '14 в 08:02
1 ответ

Один JMS Consumer перестает слушать активную тему mq, а второй нет

Процесс пружинного кварца выполняется в моем проекте каждые 15 минут, т.е. 96 раз в день. Это извлекает определенные записи из базы данных и отправляет их в службу REST (работает на JBoss 7). Эти записи, как правило, насчитывают от 50 до 100. На слу…
21 ноя '14 в 09:03
2 ответа

Верблюжий маршрут с независимым читателем очереди сообщений

У меня есть приложение с интерфейсом веб-службы, разработанное с использованием верблюда на JBoss FUSE, и я сохраняю полученные сообщения в базе данных без каких-либо проблем. Но теперь мне нужно улучшить его, чтобы он занимал несколько трудоемких п…
18 янв '17 в 11:12
1 ответ

VB6 и ActiveMQ

Как я могу использовать темы в ActiveMQ с VB6? Есть ли другой способ, кроме использования REST API?
26 фев '10 в 13:07