Submit a Pull Request Report a Bug

The Stomp class

(PECL stomp >= 0.1.0)

Introducere

Represents a connection between PHP and a Stomp compliant Message Broker.

Sinopsisul clasei

Stomp {

/* Metode */

public abort ( string $transaction_id [, array $headers ] ) : bool

public ack ( mixed $msg [, array $headers ] ) : bool

public begin ( string $transaction_id [, array $headers ] ) : bool

public commit ( string $transaction_id [, array $headers ] ) : bool

public __construct ([ string $broker = ini_get("stomp.default_broker_uri") [, string $username [, string $password [, array $headers ]]]] )

public __destruct ( ) : bool

public error ( ) : string

public getReadTimeout ( ) : array

public getSessionId ( ) : string|false

public hasFrame ( ) : bool

public readFrame ([ string $class_name = "stompFrame" ] ) : stompframe

public send ( string $destination , mixed $msg [, array $headers ] ) : bool

public setReadTimeout ( int $seconds [, int $microseconds ] ) : void

public subscribe ( string $destination [, array $headers ] ) : bool

public unsubscribe ( string $destination [, array $headers ] ) : bool

}

Cuprins

Stomp::abort — Rolls back a transaction in progress
Stomp::ack — Acknowledges consumption of a message
Stomp::begin — Starts a transaction
Stomp::commit — Commits a transaction in progress
Stomp::__construct — Opens a connection
Stomp::__destruct — Closes stomp connection
Stomp::error — Gets the last stomp error
Stomp::getReadTimeout — Gets read timeout
Stomp::getSessionId — Gets the current stomp session ID
Stomp::hasFrame — Indicates whether or not there is a frame ready to read
Stomp::readFrame — Reads the next frame
Stomp::send — Sends a message
Stomp::setReadTimeout — Sets read timeout
Stomp::subscribe — Registers to listen to a given destination
Stomp::unsubscribe — Removes an existing subscription

add a note

User Contributed Notes 1 note

down

guilherme dot geronimo at gmail dot com ¶

6 years ago


In some cases (E.g. ActiveMQ), when you have many consumers you need to identify your "client-id" during the connection process, otherwise the server can misunderstand your connection and create new topics/queues:

<?php
$stomp = new Stomp($url, $user, $password, array('client-id'=> $clientId ));
?>

add a note