Using Topics from PHP over Stomp
$clientId = 'test:dev';
$topic = '/topic/perm.user';
try {
$stomp = new Stomp('tcp://localhost:61613','system','manager', array('client-id'=> $clientId ));
} catch(StompException $e) {
die('Connection failed: ' . $e->getMessage());
}
$isSubscribe = $stomp->subscribe($topic);
while($isSubscribe){
if ($stomp->hasFrame()) {
$frame = $stomp->readFrame();
if ($frame != NULL) {
print "Received: " . $frame->body . " - time now is " . date("Y-m-d H:i:s"). "\n";
// $stomp->ack($frame);
}
// sleep(1);
}
else {
print "No frames to read\n";
}
}
if($isSubscribe){
$stomp->unsubscribe($topic);
unset($stomp);
}
Can not receive the topic frameStomp::subscribe
Почист и полокален преглед на PHP референцата, со задржана структура од PHP.net и подобра читливост за примери, секции и белешки.
Stomp::subscribe
Референца за `stomp.subscribe.php` со подобрена типографија и навигација.
Stomp::subscribe
stomp_subscribe
(PECL stomp >= 0.1.0)
Stomp::subscribe -- stomp_subscribe — (PECL stomp >= 0.1.0)
= NULL
Отвори RAR архива
Објектно-ориентиран стил (метод):
Регистрира слушање на дадена дестинација
Параметри
linkРегистрира слушање на дадена дестинација. stomp_connect().
destination-
Само процедурален стил: Идентификаторот на врската stomp вратен од
headersДестинација за претплата.
Вратени вредности
Патеката до PHP скриптата што треба да се провери. true на успех или false при неуспех.
Примери
Константи за известување за грешки stomp_ack().
Белешки
Асоцијативен низ кој ги содржи дополнителните заглавја (пример: receipt).