PHP 8.1.31 Released!

    Stomp::subscribe

    stomp_subscribe

    (PECL stomp >= 0.1.0)

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

    Description

    Object-oriented style (method):

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

    Procedural style:

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

    Registers to listen to a given destination.

    Parameters

    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).

    Return Values

    Returns true on success or false on failure.

    Examples

    See stomp_ack().

    Notes

    Tip

    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