Bitrix-D7 23.9
 
Загрузка...
Поиск...
Не найдено
Интерфейс Consumer
+ Граф наследования:Consumer:

Открытые члены

 getQueue ()
 
 receive ()
 
 acknowledge (Message $message)
 
 reject (Message $message, bool $requeue=false)
 

Подробное описание

См. определение в файле consumer.php строка 5

Методы

◆ acknowledge()

acknowledge ( Message $message)

Tell the MQ broker that the message was processed successfully.

◆ getQueue()

getQueue ( )

Gets the Queue associated with this queue receiver.

Замещается в GroupHash и Simple.

◆ receive()

receive ( )

Receives the next message that arrives within the specified timeout interval. This call blocks until a message arrives, the timeout expires, or this message consumer is closed. A timeout of zero never expires, and the call blocks indefinitely.

Timeout is in milliseconds

◆ reject()

reject ( Message $message,
bool $requeue = false )

Tell the MQ broker that the message was rejected.