Stomp::ack
stomp_ack
(PECL stomp >= 0.1.0)
Stomp::ack -- stomp_ack — Acknowledges consumption of a message
説明
オブジェクト指向型 (method):
public Stomp::ack
( mixed $msg
[, array $headers
] ) : bool
手続き型:
stomp_ack
( resource $link
, mixed $msg
[, array $headers
] ) : bool
Acknowledges consumption of a message from a subscription using client acknowledgment.
パラメータ
link- 手続き型のみ: stomp_connect() が返す stomp リンク ID。
msg- The message/messageId to be acknowledged.
headers- 追加のヘッダ (例: receipt) を含む連想配列。
返り値
成功した場合に true を、失敗した場合に false を返します。
注意
注意:
トランザクションヘッダを指定し、そのメッセージがトランザクションの一部であることを示します。
ヒント Stomp は本来非同期です。同期通信を実装するには receipt ヘッダを追加します。これを追加すると、サーバーがメッセージを受領するかタイムアウトに達するまではメソッドが何も返さないようになります。
例
例1 オブジェクト指向型
<?php$queue = '/queue/foo';$msg = 'bar';/* connection */try { $stomp = new Stomp('tcp://localhost:61613');} catch(StompException $e) { die('Connection failed: ' . $e->getMessage());}/* send a message to the queue 'foo' */$stomp->send($queue, $msg);/* subscribe to messages from the queue 'foo' */$stomp->subscribe($queue);/* read a frame */$frame = $stomp->readFrame();if ($frame->body === $msg) { /* acknowledge that the frame was received */ $stomp->ack($frame);}/* remove the subscription */$stomp->unsubscribe($queue);/* close connection */unset($stomp);?>
例2 手続き型
<?php$queue = '/queue/foo';$msg = 'bar';/* connection */$link = stomp_connect('ssl://localhost:61612');/* check connection */if (!$link) { die('Connection failed: ' . stomp_connect_error());}/* begin a transaction */stomp_begin($link, 't1');/* send a message to the queue 'foo' */stomp_send($link, $queue, $msg, array('transaction' => 't1'));/* commit a transaction */stomp_commit($link, 't1');/* subscribe to messages from the queue 'foo' */stomp_subscribe($link, $queue);/* read a frame */$frame = stomp_read_frame($link);if ($frame['body'] === $msg) { /* acknowledge that the frame was received */ stomp_ack($link, $frame['headers']['message-id']);}/* remove the subscription */stomp_unsubscribe($link, $queue);/* close connection */stomp_close($link);?>
