API службы сообщений Java (JMS) - это API промежуточного программного обеспечения Java (MOM) для отправки сообщений между двумя или более клиентами. JMS является частью платформы Java, Enterprise Edition, и определяется спецификацией, разработанной в рамках процесса сообщества Java.
3 ответа

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

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

JMS TextMessage itext PDF-подпись заголовка не найдена

У меня есть слушатель, который получает JMS TextMessage, в котором есть PDF-контент. Я делаю getBytes ("Cp037"), так как он исходит от мэйнфрейма когда я запускаю строку "PdfReader reader = new PdfReader (bais)"; происходит сбой, если подпись заголо…
03 мар '11 в 17:04
2 ответа

JMS - общее использование

Каковы общие и полезные применения JMS и Message Driven Beans?
13 мар '10 в 17:14
5 ответов

Долгоживущие сеансы JMS. Хранение соединений JMS / сеансов JMS всегда открывало плохую практику?

Хранение JMS-соединений / сессий / потребителей всегда является плохой практикой? Пример проекта кода: // app startup code ConnectionFactory cf = (ConnectionFactory)jndiContext.lookup(CF_JNDI_NAME); Connection connection = cf.createConnection(user,p…
07 ноя '08 в 23:59
2 ответа

Программно создавать объекты JMS в Glassfish 3.1.2

Я использую Glassfish 3.1.2. Можно ли администрировать сервер через какой-то код Java? И я не имею в виду бег asadmin Команда через класс Process. Например, я хотел бы создать очередь JMS. Обычно я создавал это так: войти в консоль администратора пе…
27 мар '12 в 22:58
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
0 ответов

Фильтр содержимого тела JMS

Я работаю над JMS. Я создаю TextMessage и добавляю к нему некоторый текст ("Hello World"). Теперь я хочу отфильтровать сообщения на основе слов / содержимого ("Hello") в теле сообщения. Я пытался использовать селектор, но я думаю, что это только сво…
26 апр '13 в 01:05
2 ответа

Spring JmsTemplate - добавить пользовательское свойство

Я использую Spring API JmsTemplate а также MappingJackson2MessageConverter (версия: spring-jms-4.3.4.RELEASE.jar) публиковать сообщения в теме ActiveMQ, как показано в приведенном ниже коде. ТемаПубликатор класса: @Component public class TopicPublis…
21 фев '17 в 12:25
1 ответ

JMS-фильтрация с использованием XPATH

У меня есть требование, в котором мне нужно фильтровать сообщения JMS в соответствии с XPATH. Я попытался использовать свойство JCA, как показано ниже. Но он не выбирал никаких сообщений JMS. property name = "MessageSelector" value = "JMS_BEA_SELECT…
20 авг '14 в 19:24
1 ответ

Потребитель Weblogic JMS - использование XPath в селекторе с кавычками

Я пытаюсь подписаться на сообщения WebLogic JMS, используя селектор, содержащий XPath. В WebLogic это достигается с помощью функции "JMS_BEA_SELECT". Что-то вроде этого: session.createConsumer(topic, "JMS_BEA_SELECT('xpath', '/Parent/text()') = '123…
20 ноя '13 в 09:34
1 ответ

Должен ли я отписаться от недолговечного абонента JMS Topic?

Я пишу Java JMS-приложение, которое отвечает за взаимодействие между узлами кластера. Обмен сообщениями осуществляется путем публикации \ подписки с использованием темы. TopicSubscriber создается путем вызова TopicSession.createSubscriber(topic, nul…
23 май '12 в 14:41
2 ответа

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

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

AmqpProvider - Транспортное соединение удаленно закрыто

Я использую ServiceMix вместе с библиотеками Apache Camel и Qpid для подключения к удаленному узлу для получения очередей JMS. Моя конфигурация Bean: <bean id="amqp" class="org.apache.camel.component.amqp.AMQPComponent"> <property name="con…
09 май '17 в 20:11
0 ответов

Транзакция JMS - после коммита

В моем приложении я использую Spring's DefaultMessageListenerContainer с sessionTransacted установлен в true, Мне нужно выполнить метод, который будет вызываться только в случае успешного выполнения слушателя, что означает, что сеанс JMS зафиксирова…
16 окт '18 в 19:47
2 ответа

Какие библиотеки HornetQ мне нужны для клиента JMS?

У меня есть автономный сервер Hornetq и клиент JMS, работающий с ним! Что касается руководства пользователя hornetq, я должен добавить только jnp-client.jar и jms.jar в classpath клиента. Но когда я пытаюсь использовать сервер hornetq (генерировать …
06 ноя '12 в 07:34
0 ответов

Jboss WildFly JMS кластер - сообщения отправляются только одному узлу во время каждого запуска

Мы пытаемся настроить JBoss JMS кластер для распределения нагрузки. Сообщается о проблеме использования MDB для балансировки нагрузки. Я не уверен, есть ли обходной путь / исправление для этого, но мы действительно хотим отправить сообщение в класт…
26 фев '15 в 13:33
1 ответ

Отправка сообщения в очереди сообщений сервера Glassfish

Я просто тестирую, чтобы отправить сообщение в очередь сервера Glassfish, поэтому для этого я создал JMSResource на сервере Glassfish, например: И теперь я создал одно приложение Java в IDE Netbeans. Это мой файл Java:- import javax.annotation.Resou…
30 ноя '12 в 07:52
2 ответа

Бин, управляемый сообщениями, с Java Message Queue

У меня есть следующая проблема при развертывании моего приложения. Он использует JMS и удаленный openMQ для связи между серверами. Проблема в том, что соединение не является полностью надежным, поэтому оно может быть вверх или вниз. Для переподключе…
16 мар '10 в 09:52
1 ответ

Как отправить или отобразить ответ на запрошенные темы без использования какого-либо веб-сервера?

Я создаю около 10 потоков, и эти потоки отправят запрос в JMS. и у меня есть получатель, который будет соответствовать идентификатору корреляции из ответа на переданный идентификатор корреляции, если он совпадает, то этот ответ должен соответствоват…
14 мар '17 в 10:18
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