Stomp::ack

    stomp_ack

    (PECL stomp >= 0.1.0)

    Stomp::ack -- stomp_ack — Подтверждает получение сообщения

    Описание

    Объектно-ориентированный стиль (метод):

    publicStomp::ack(mixed$msg, array$headers = ?): bool

    Процедурный стиль:

    stomp_ack(resource$link, mixed$msg, array$headers = ?): bool

    Подтверждает факт получения сообщения из очереди, используя подтверждение клиента.

    Список параметров

    link

    Только для процедурного стиля: идентификатор соединения stomp, полученный из stomp_connect().

    msg

    Сообщение/идентификатор сообщения, получение которого должно быть подтверждено.

    headers

    Ассоциативный массив, содержащий дополнительные заголовки (пример: receipt).

    Возвращаемые значения

    Возвращает true в случае успешного выполнения или false, если возникла ошибка.

    Примеры

    Пример #1 Объектно-ориентированный стиль

    <?php

    $queue     = '/queue/foo';
    $msg = 'bar';


    try {
    $stomp = new Stomp('tcp://localhost:61613');
    } catch(    StompException $e) {
    die(    'Ошибка соединения: ' . $e->getMessage());
    }


    $stomp->send($queue, $msg);


    $stomp->subscribe($queue);


    $frame = $stomp->readFrame();

    if (    $frame->body === $msg) {

    $stomp->ack($frame);
    }


    $stomp->unsubscribe($queue);


    unset($stomp);

    ?>

    Пример #2 Процедурный стиль

    <?php

    $queue     = '/queue/foo';
    $msg = 'bar';


    $link = stomp_connect('ssl://localhost:61612');


    if (!$link) {
    die(    'Ошибка соединения: ' . stomp_connect_error());
    }


    stomp_begin($link, 't1');


    stomp_send($link, $queue, $msg, array('transaction' => 't1'));


    stomp_commit($link, 't1');


    stomp_subscribe($link, $queue);


    $frame = stomp_read_frame($link);

    if (    $frame['body'] === $msg) {

    stomp_ack($link, $frame['headers']['message-id']);
    }


    stomp_unsubscribe($link, $queue);


    stomp_close($link);

    ?>

    Примечания

    Замечание:

    Также может быть указан заголовок транзакции, означающий что приём сообщения должен являться частью именованной транзакции.

    Подсказка

    Stomp асинхронен по своей сути. Синхронная связь может быть реализована добавлением receipt-заголовка. Это заставит методы ничего не возвращать, пока сервер не подтвердит получение сообщения или не будет превышено время ожидания сообщения.

    To Top