Class TestConsumer
Test Consumer
Minimal consumer implementation for testing.
Namespace: Cake\Queue\TestSuite\Transport
Property Summary
-
$queue protected
Interop\Queue\QueueQueue
Method Summary
-
__construct() public
Constructor
-
acknowledge() public
Acknowledge message
-
getQueue() public
Get queue
-
receive() public
Receive message
-
receiveNoWait() public
Receive no wait
-
reject() public
Reject message
Method Detail
__construct() ¶ public
__construct(Interop\Queue\Queue $queue)Constructor
Parameters
-
Interop\Queue\Queue$queue Queue
acknowledge() ¶ public
acknowledge(Message $message): voidAcknowledge message
Parameters
-
Message$message Message
Returns
voidreceive() ¶ public
receive(int|null $timeout = null): Interop\Queue\Message|nullReceive message
Timeout is in milliseconds
Parameters
-
int|null$timeout optional Timeout in milliseconds
Returns
Interop\Queue\Message|nullreceiveNoWait() ¶ public
receiveNoWait(): Interop\Queue\Message|nullReceive no wait
Returns
Interop\Queue\Message|nullreject() ¶ public
reject(Message $message, bool $requeue = false): voidReject message
Parameters
-
Message$message Message
-
bool$requeue optional Requeue flag
Returns
void