PHP 8.4.1 Released!

    Stomp::subscribe

    stomp_subscribe

    (PECL stomp >= 0.1.0)

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

    Descrição

    Estilo orientado a objetos (method):

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

    Estilo procedural:

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

    Registers to listen to a given destination.

    Parâmetros

    link

    Somente no estilo procedural: O identificador do link stomp retornado por stomp_connect().

    destination

    Destination to subscribe to.

    headers

    Um array associativo contendo os cabeçalhos adicionais (exemplo: receipt).

    Valor Retornado

    Retorna true em caso de sucesso ou false em caso de falha.

    Exemplos

    See stomp_ack().

    Notas

    Dica

    O Stomp é naturalmente assíncrono. Comunicação síncrona pode ser implementada adicionando um cabeçalho receipt. Isso fará com que os métodos não retornem nada até que o servidor confirme o recebimento da mensagem ou até que o tempo limite de leitura seja atingido.

    Melhore Esta Página

    Aprenda Como Melhorar Esta Página • Envie uma Solicitação de Modificação • Reporte um Problema
    ＋adicione uma nota

    Notas Enviadas por Usuários (em inglês) 1 note

    up
    -1
    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
    ＋adicione uma nota
    To Top