Articles of activemq

PHP Stomp: чтение всех сообщений в очереди

Мне нужно найти конкретное сообщение в очереди ActiveMQ с помощью PHP и удалить его. AFAIK единственный способ сделать это – прочитать все сообщения, которые в настоящее время поставлены в очередь, и ACK – одно из сообщений, которое меня интересует. ( Пример в руководстве PHP для Stomp :: ack делает более-менее то же самое, t читать […]

Общение между PHP и Java с помощью ActiveMQ / Stomp

Задний план У меня есть две службы, которые должны общаться друг с другом в очереди сообщений. Один из них – устаревшая служба, написанная на PHP, а другая – на Java. Рано, чем позже, служба PHP будет переписана на Java. Нынешний способ общения друг с другом состоит в том, чтобы писать в общую базу данных, которую […]

Клиентская библиотека PHP Stomp для ActiveMQ + WebSockets

Я установил ActiveMQ с поддержкой WebSocket, и я могу получить JS-демо. Проблема, с которой я сейчас сталкиваюсь, заключается в том, что библиотека PHP Stomp не будет работать с URI WebSocket, поэтому, когда я попробую: $ stomp = new Stomp ('ws: // localhost: 61614'); Я получаю: Ошибка подключения: неверная схема URI брокера Любые мысли о том, […]

HTTP-сообщение из ActiveMQ с помощью Camel

Мы используем маршруты верблюдов для отправки значений из очереди в конечную точку http. Я успешно настроил маршрут, используя http-компонент верблюда, но я не могу получить сообщение о сообщении jms. Например, мой маршрут настроен следующим образом: <route errorHandlerRef="dlc" autoStartup="true" id="route2" xmlns:ns2="http://camel.apache.org/schema/web" xmlns="http://camel.apache.org/schema/spring"> <from uri="activemq:test"/> <setHeader headerName="CamelHttpMethod"> <constant>POST</constant> </setHeader> <to uri="http://localhost/tim/camel/" id="to2"/> </route> Это приводит к POST, […]