PHP 8.5.0 Alpha 2 available for testing

Stomp::subscribe

stomp_subscribe

(PECL stomp >= 0.1.0)

Stomp::subscribe -- stomp_subscribeRegistrarse para escuchar a un destino dado

Descripción

Estilo orientado a objetos (método):

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

Estilo procedimental:

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

Registrarse para escuchar a un destino dado.

Parámetros

link

Estilo procedimental únicamente: El identificador stomp devuelto por la funciónstomp_connect().

destination

Destino al que suscribirse.

headers

Array asociativo que contiene los encabezados adicionales (ejemplo: receipt).

Valores devueltos

Esta función retorna true en caso de éxito o false si ocurre un error.

Ejemplos

Vea stomp_ack().

Notas

Sugerencia

Stomp es, por naturaleza, asíncrono. Una comunicación síncrona puede ser implementada añadiendo un encabezado receipt. Esto hará que los métodos no devuelvan nada hasta que el mensaje de confirmación no haya sido recibido o hasta que el tiempo de espera no sea alcanzado.

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
To Top