Открытые члены | |
process (Message $message) | |
Открытые атрибуты | |
const | ACK = 'enqueue.ack' |
const | REJECT = 'enqueue.reject' |
const | REQUEUE = 'enqueue.requeue' |
См. определение в файле processor.php строка 4
process | ( | Message | $message | ) |
The method has to return either self::ACK, self::REJECT, self::REQUEUE string.
The method also can return an object. It must implement __toString method and the method must return one of the constants from above.
Message | $message | |
Context | $context | // removed - It's not clear why it's here |
const ACK = 'enqueue.ack' |
Use this constant when the message is processed successfully and the message could be removed from the queue.
См. определение в файле processor.php строка 9
const REJECT = 'enqueue.reject' |
Use this constant when the message is not valid or could not be processed The message is removed from the queue.
См. определение в файле processor.php строка 15
const REQUEUE = 'enqueue.requeue' |
Use this constant when the message is not valid or could not be processed right now, but we can try again later The original message is removed from the queue but a copy is published to the queue again.
См. определение в файле processor.php строка 21