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