Consumer
Table of Contents
Methods
- acknowledge() : void
- Tell the MQ broker that the message was processed successfully.
- getQueue() : Queue
- Gets the Queue associated with this queue receiver.
- receive() : Message|null
- Receives the next message that arrives within the specified timeout interval.
- reject() : void
- Tell the MQ broker that the message was rejected.
Methods
acknowledge()
Tell the MQ broker that the message was processed successfully.
public
acknowledge(Message $message) : void
Parameters
- $message : Message
getQueue()
Gets the Queue associated with this queue receiver.
public
getQueue() : Queue
Return values
Queuereceive()
Receives the next message that arrives within the specified timeout interval.
public
receive() : Message|null
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
Return values
Message|nullreject()
Tell the MQ broker that the message was rejected.
public
reject(Message $message[, bool $requeue = false ]) : void
Parameters
- $message : Message
- $requeue : bool = false