Мне нужно найти конкретное сообщение в очереди ActiveMQ с помощью PHP и удалить его. AFAIK единственный способ сделать это – прочитать все сообщения, которые в настоящее время поставлены в очередь, и ACK – одно из сообщений, которое меня интересует. ( Пример в руководстве PHP для Stomp :: ack делает более-менее то же самое, t читать […]
Задний план У меня есть две службы, которые должны общаться друг с другом в очереди сообщений. Один из них – устаревшая служба, написанная на PHP, а другая – на Java. Рано, чем позже, служба PHP будет переписана на Java. Нынешний способ общения друг с другом состоит в том, чтобы писать в общую базу данных, которую […]
Я установил ActiveMQ с поддержкой WebSocket, и я могу получить JS-демо. Проблема, с которой я сейчас сталкиваюсь, заключается в том, что библиотека PHP Stomp не будет работать с URI WebSocket, поэтому, когда я попробую: $ stomp = new Stomp ('ws: // localhost: 61614'); Я получаю: Ошибка подключения: неверная схема URI брокера Любые мысли о том, […]
Я использую клиент PHP Stomp для отправки сообщения stomp. Я хотел бы оставить постоянное соединение открытым, на заднем плане, и отправлять сообщения время от времени. Однако я не могу найти способ справиться с ошибками соединения, если они произойдут после открытия соединения (при отправке ()). Например, при запуске: <?php $stomp = new Stomp('tcp://localhost:61613'); sleep(5); // Connection […]