rabbitmq AMQP :: consumume()

Question

AMQP function consume() - функция блокировки с обратным вызовом, Возможно ли установить тайм-аут для функции потребления(), поэтому через определенное время он больше не блокируется и выполнение кода завершено?

Answer 1

Да, вот как:

$amqp = new AMQPConnection($your_connection_params); 
$amqp->setTimeout($seconds); 

Затем, когда вы вызываете потреблять() в очереди, если никакие сообщения не прибывают в течение периода тайм-аута, AMQPException будет выброшен из потреблять() с сообщением , «Ресурс временно недоступен». Если вы когда-либо выходите из потребления() или набираете тайм-аут, обязательно вызывайте cancel() в объекте очереди, чтобы правильно сбросить потребитель. Для того, чтобы сделать это, вам нужно создать глобально уникальный потребительский тег и передать его в качестве недокументированных, третий параметр потреблять:

$tag = uniqid() . microtime(true); 
$queue->consume($callback, $flags, $tag); 
$queue->cancel($tag); 

Таким образом, вы можете позвонить потреблять() еще раз позже без странных вопросов, заставит голову вращаться.