Как прочитать сообщение из темы ActiveMQ PHP Stomp Persistent - PullRequest
Новая
       11

Как прочитать сообщение из темы ActiveMQ PHP Stomp Persistent

0 голосов
/ 26 октября 2018

В php я могу читать сообщения из activeMQ с Stomp следующим образом: 

$consumer = new Stomp("tcp://localhost:61613");
$consumer->clientId = "test";
$consumer->connect();
$consumer->subscribe("/topic/test");
$msg = $consumer->readFrame();

if ( $msg != null) {
    echo "Message '$msg->body' received from topic\n";
    $consumer->ack($msg);
} else {
    echo "Failed to receive a message\n";
}

Но после прочтения одного сообщения конец сценария php (кажется логичным), как мы можем иметь (как в JAVA) всегдаактивный потребитель, который может прочитать сообщение, когда производитель отправит его в очередь?

...