Граф наследования: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.

Объявления и описания членов интерфейса находятся в файле:

C:/bitrix/modules/calendar/lib/core/queue/interfaces/consumer.php