AMQPQueue::getName
You can use nack with consume, using those flags :
- On consume method : AMQP_NOPARAM
- On nack method : AMQP_REQUEUE
AMQPQueue::nack
(PECL amqp >= Unknown)
AMQPQueue::nack — メッセージを明示的に受付前の状態にする
説明
public void AMQPQueue::nack
( string
$delivery_tag
[, string $flags = AMQP_NOPARAM
] )
メッセージ delivery_tag を、明示的に受付前の状態にします。
このメソッドをコールできるのは、まだ受け付けられていないメッセージだけです。
つまり、 AMQPQueue::consume() や AMQPQueue::get()
で AMQP_AUTOACK フラグを使った場合はこのメソッドを使えません。
このメソッドがコールされると、ブローカは即時にメッセージをキューに戻し、 接続を閉じるまで待ちません。
このメソッドをサポートするのは RabbitMQ ブローカだけです。 他のブローカに接続しているときにこのメソッドをコールした場合の挙動は未定義です。
パラメータ
-
delivery_tag -
メッセージを識別するための配送タグ。
-
flags -
フラグのビットマスク。
エラー / 例外
チャネルが開いていない場合に AMQPChannelException をスローします。
ブローカへの接続が途切れた場合に AMQPConnectionException をスローします。
返り値
成功した場合に TRUE を、失敗した場合に FALSE を返します。
add a note
User Contributed Notes
AMQPQueue::nack - [1 notes]