Stomp::subscribe

    stomp_subscribe

    (PECL stomp >= 0.1.0)

    Stomp::subscribe -- stomp_subscribe — Registers to listen to a given destination

    Açıklama

    Nesne yönelimli kullanım (method):

    public Stomp::subscribe(string $destination, array $headers = ?): bool

    Yordamsal kullanım:

    stomp_subscribe(resource $link, string $destination, array $headers = ?): bool

    Registers to listen to a given destination.

    Bağımsız Değişkenler

    link

    Procedural style only: The stomp link identifier returned by stomp_connect().

    destination

    Destination to subscribe to.

    headers

    Associative array containing the additional headers (example: receipt).

    Dönen Değerler

    Başarı durumunda true, başarısızlık durumunda false döner.

    Örnekler

    See stomp_ack().

    Notlar

    İpucu

    Stomp is inherently asynchronous. Synchronous communication can be implemented adding a receipt header. This will cause methods to not return anything until the server has acknowledged receipt of the message or until read timeout was reached.

    Found A Problem?

    Learn How To Improve This Page • Submit a Pull Request • Report a Bug
    ＋add a note

    User Contributed Notes 1 note

    up
    0
    holycd
    8 years ago
    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 frame
    ＋add a note
    To Top