RabbitMQ

Пометка сообщения в очереди как обработанного:

$amqpMessage->delivery_info['channel']->basic_ack($amqpMessage->delivery_info['delivery_tag']);

Отклонение сообщения из текущей очереди:

$message->delivery_info['channel']->basic_reject($message->delivery_info['delivery_tag'], false);

Источник: 1


02.10.2010 13:41

Комментарии

(yea)
Max |

Copyrights © 2007 - 2026 YaPro.Ru