psr-queue/PsrProcessor.php at master · php-enqueue/psr-queue

This repository was archived by the owner on Dec 12, 2018. It is now read-only.

36 lines (31 loc) · 1.12 KB

<?php

namespace Enqueue\Psr;

interface PsrProcessor

{

/**

* Use this constant when the message is processed successfully and the message could be removed from the queue.

const ACK = 'enqueue.ack';

/**

* Use this constant when the message is not valid or could not be processed

* The message is removed from the queue.

const REJECT = 'enqueue.reject';

/**

* 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 publsihed to the queue again.

const REQUEUE = 'enqueue.requeue';

/**

* 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.

* @param PsrMessage $message

* @param PsrContext $context

* @return string|object with __toString method implemented

public function process(PsrMessage $message, PsrContext $context);

}

Navigation Menu