PHP 8.4.0 RC4 available for testing

    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.

    Improve This Page

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

    User Contributed Notes 1 note

    up
    0
    holycd
    7 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