class Stomp
{
public abort(
string $transaction_id,
array $headers = ?):
bool
stomp_abort(resource $link, string $transaction_id, array $headers = ?): bool
public ack(
mixed $msg,
array $headers = ?):
bool
stomp_ack(
resource $link,
mixed $msg,
array $headers = ?):
bool
public begin(
string $transaction_id,
array $headers = ?):
bool
stomp_begin(resource $link, string $transaction_id, array $headers = ?): bool
public commit(
string $transaction_id,
array $headers = ?):
bool
stomp_commit(resource $link, string $transaction_id, array $headers = ?): bool
public __construct(
string $broker = ini_get("stomp.default_broker_uri"),
string $username = ?,
string $password = ?,
array $headers = ?)
stomp_connect(
string $broker = ini_get("stomp.default_broker_uri"),
string $username = ?,
string $password = ?,
array $headers = ?
): resource
stomp_close(resource $link): bool
stomp_error(resource $link): string
stomp_get_read_timeout(resource $link): array
stomp_get_session_id(resource $link): string|false
stomp_has_frame(resource $link): bool
stomp_read_frame(resource $link): array
public send(
string $destination,
mixed $msg,
array $headers = ?):
bool
stomp_send(
resource $link,
string $destination,
mixed $msg,
array $headers = ?):
bool
stomp_set_read_timeout(resource $link, int $seconds, int $microseconds = ?): void
public subscribe(
string $destination,
array $headers = ?):
bool
stomp_subscribe(resource $link, string $destination, array $headers = ?): bool
public unsubscribe(
string $destination,
array $headers = ?):
bool
stomp_unsubscribe(resource $link, string $destination, array $headers = ?): bool
}