Simple implements Consumer
Table of Contents
Interfaces
Methods
- __construct() : mixed
- acknowledge() : void
- Tell the MQ broker that the message was processed successfully.
- getPackSize() : int
- 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.
- setPackSize() : void
Methods
__construct()
public
__construct(Queue $queue) : mixed
Parameters
- $queue : Queue
acknowledge()
Tell the MQ broker that the message was processed successfully.
public
acknowledge(Message $message) : void
Parameters
- $message : Message
getPackSize()
public
getPackSize() : int
Return values
intgetQueue()
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
Tags
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
setPackSize()
public
setPackSize(int $packSize) : void
Parameters
- $packSize : int