Apache Qpid™ - это кроссплатформенная корпоративная система обмена сообщениями, которая реализует протокол расширенной очереди сообщений (AMQP), предоставляя брокеров сообщений, написанных на C++ и Java, а также клиентов для C++, Java JMS, .NET, Python и Ruby.
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
1 ответ

Обработка ошибок API Qpid Proton Messenger

Я отчаянно пытаюсь справиться с ошибками при отправке сообщений с помощью Qpid Proton AMQP Messenger API для Python. Это пример сеанса отправки сообщения от интерактивного интерпретатора Python при отправке в несуществующую очередь myqueue на брокер…
16 июл '14 в 14:34
3 ответа

Где Apache Derby хранит свои файлы при использовании с Apache Qpid?

Я использую Derby DB в качестве хранилища для моего Qpid-брокера. Попытка выяснить, где Derby хранит файлы данных, когда работает как встроенная БД. У кого-нибудь есть подсказка, где находятся файлы или как настроить каталог для использования?
21 ноя '12 в 15:23
1 ответ

Поддержка AMQP 1.0 в ActiveMQ - невозможно установить предварительную выборку

Мы пытаемся построить систему очереди заданий поверх ActiveMQ 5.9.1. Мы используем поддержку AMQP 1.0 в activemq, в настоящее время мы используем библиотеку qpid jms для клиентского кода. Для целей системы очереди заданий жизненно важно, чтобы мы мо…
10 июн '14 в 08:20
0 ответов

Используйте Azure-EventHubs-клиентов для подключения к брокеру QPid AMQP 1.0?

Если я использую https://github.com/Azure/azure-event-hubs для подключения клиентов к Azure EventHubs в облаке, могу ли я использовать этот же код клиента для подключения к брокеру QPid AMQP 1.0? Я не могу найти никакой подробной документации о том,…
21 авг '17 в 19:35
2 ответа

Qpid JMS Опции для CloudBees?

Я знаю, что CloudBees не предоставляют службу очереди сообщений. В моем приложении Java EE я использовал RabbitMQ в качестве брокера, Qpid JMS в качестве клиента. Это не работает из-за: [# | 2013-11-09T20: 21: 45.203 + 0000 | INFO | glassfish 4.0 | …
09 ноя '13 в 21:01
1 ответ

ServiceBus over AMQP закрывает потребителя

У нас есть локальная установка ServiceBus и Java JMS QPID-клиента 0.26. Кажется, в SB есть ошибка - он отправляет команду END потребителю, когда производитель закрывает соединение. И производитель, и потребитель должны работать на одной машине. Перв…
26 фев '14 в 15:51
0 ответов

Интеграционные тесты с RabbitMQ

В настоящее время я работаю над некоторым приложением Spring Boot 2.x, взаимодействующим с RabbitMQ. Я хотел бы создать интеграционный тест для тестирования всего приложения. логика, включая взаимодействие с кроликом. Пока мне нужна легкая автономна…
2 ответа

Получатель Qpid в Azure EventHub

У меня уже есть работающее приложение на основе Azure EventHub. Теперь мне нужно написать приемник Java, который подключается к существующей инфраструктуре. Существующая конфигурация: Концентратор событий> SomeName > Группа потребителей> SomeGroupNa…
14 ноя '16 в 20:22
2 ответа

How can I Send/Receive a message from Azure Service Bus from Qpid JMS (qpid-jms-client-0.11.1.jar)?

I am currently researching how to connect to Azure Service Bus using Qpid JMS (qpid-jms-client-0.11.1.jar). I have created a Demo Java application SimpleSenderReceiver which connects to an already configured Azure Service Bus using the following gui…
27 окт '16 в 09:39
1 ответ

Как бороться с потерянными клиентскими подключениями в Apache Qpid + MRg

При использовании клиента C++ создается впечатление, что если по какой-либо причине соединение с сервером теряется, например, из-за сбоя питания, ручного завершения работы, сети, сервер не обнаруживает потерю клиента. Открытое соединение (или наполо…
09 апр '13 в 10:47
1 ответ

Ошибка связи с qpid-proton-0.17.0

Когда я собираю свою программу qpid-proton-0.17.0, я получаю эту ссылку: undefined reference to proton::event_loop::inject(std::function<void ()>) Вот как я строю: g++ -std=c++14 myprog.cpp -o myprog -lqpid-proton-cpp -lboost_system -lcrypto -…
17 май '17 в 16:19
1 ответ

Qpid Proton: отправка сообщений по двум направлениям

В настоящее время я могу отправлять сообщения в одну очередь "devQueue". Когда сообщение поступает в "devQueue", его также необходимо отправить в "localQueue". Я считаю эту реализацию сложной. Я попытался вызвать другой класс "local_send" из класса …
1 ответ

Не удается создать экземпляр класса: org.apache.qpid.jndi.PropertiesFileInitialContextFactory

Я пишу Qpid-клиент, который отправляет сообщение. Пример кода, который я использую: private void runTest() throws Exception { Properties properties = new Properties(); properties.load(this.getClass().getResourceAsStream("helloworld.properties")); Co…
04 май '17 в 18:06
0 ответов

Qpid соединение отказано

Я использую 0.32 Qpid JMS-клиента в моем приложении для весенней загрузки. Ниже приведены файлы конфигурации и свойств: JmsConfiguration.java @Configuration public class JmsConfiguration { @Primary @Bean public Context createContext() { Properties p…
25 фев '16 в 01:21
1 ответ

Delyaed плагин сообщений для Apache qpid

Я использую apache qpid в качестве брокера для написания джунитов. Мой вариант использования требует использования функциональности отложенных сообщений в тестах. и qpid поддерживает это, как rabbitmq. У меня есть любой плагин, который я могу написа…
27 июн '18 в 06:36
3 ответа

Ищете скомпилированную библиотеку Python AMQP

Мы создаем высокопроизводительный клиент AMQP, использующий Qpid в качестве посредника, и мы не приближаемся к пропускной способности, о которой сообщалось в других местах. (Мы получаем скорость менее 250 мсг / с, в то время как эта запись в блоге у…
05 май '11 в 21:02
1 ответ

Android: создание фабрики JNDI от размышлений о том, что Android форсирует javax

Я пытаюсь портировать: Apache Qpid Client, JMS и JNDI - на Android. Я могу получить успешную компиляцию / сборку моего проекта QpidDroid при запуске целей установки ant debug после передачи Dalvik параметра --core-library, чтобы разрешить пакеты jav…
19 янв '12 в 16:15
1 ответ

Исключение в потоке "main" java.lang.NoClassDefFoundError: org/apache/qpid/url/URLSyntaxException

Я использую QPid с Eclipse и Tomcat. Создано динамическое веб-приложение и заданы переменные среды QPID_HOME, QPID_WORK. Попробуйте пример Hello.java, упомянутый здесь: https://svn.apache.org/repos/asf/qpid/trunk/qpid/java/client/example/ Но я получ…
23 июл '12 в 16:57
1 ответ

Простой пример записи в Java-брокер Qpid с неработающим Qpid Proton

Я новичок в AMQP и пытаюсь написать простое приложение, которое пишет в Qpid Java Broker с API Qpid Proton Messenger. Из коробки Java-брокер Qpid имеет четыре обмена по умолчанию (amq.match, amq.fanout, amq.topic, amq.direct), "порт" AMQP на порту 5…
17 июн '15 в 00:59