-
Notifications
You must be signed in to change notification settings - Fork 351
/
MessageProcessorInterface.php
34 lines (28 loc) · 1.08 KB
/
MessageProcessorInterface.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
<?php
namespace Oro\Component\MessageQueue\Consumption;
use Oro\Component\MessageQueue\Transport\MessageInterface;
use Oro\Component\MessageQueue\Transport\SessionInterface;
interface MessageProcessorInterface
{
/**
* Use this constant when the message is processed successfully and the message could be removed from the queue.
*/
const ACK = 'oro.message_queue.consumption.ack';
/**
* Use this constant when the message is not valid or could not be processed
* The message is removed from the queue
*/
const REJECT = 'oro.message_queue.consumption.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 published to the queue again.
*/
const REQUEUE = 'oro.message_queue.consumption.requeue';
/**
* @param MessageInterface $message
* @param SessionInterface $session
*
* @return string
*/
public function process(MessageInterface $message, SessionInterface $session);
}