В настоящее время я использую команду «Stomp» для отправки и получения / потребления сообщений в очередях activemq, но потребитель «Stomp» работает синхронно, что означает, что потребитель «Stomp» продолжает проверять, есть ли в очереди какие-либо новые сообщения. Но что мне нужно сделать, так это сделать activemq уведомлять моего потребителя, когда новое сообщение попадает в очередь. как, например, метод Onmessage () в Java. Я искал несколько дней, но все равно не повезло. мой текущий php-код (как я читаю сообщения из очереди с помощью педали):
while (true) {
$frame = $stomp->readFrame();
if ($frame != NULL) {
print "Received: " . $frame->body . " - time now is " . date("Y-m-d H:i:s"). "\n";
$stomp->ack($frame);
}
else {
print "No frames to read\n";
}