1 | <?php |
||
10 | class DirectPublisher implements Publisher |
||
11 | { |
||
12 | /** |
||
13 | * @var ConsumerWrapper |
||
14 | */ |
||
15 | private $consumer; |
||
16 | |||
17 | /** |
||
18 | * @var MessageInEnvelopSerializer |
||
19 | */ |
||
20 | private $serializer; |
||
21 | |||
22 | /** |
||
23 | * @var string |
||
24 | */ |
||
25 | private $queueName; |
||
26 | |||
27 | private $messages = []; |
||
28 | |||
29 | private $delayedMessages = []; |
||
30 | |||
31 | /** |
||
32 | * @param ConsumerWrapper $consumer |
||
33 | */ |
||
34 | public function __construct(ConsumerWrapper $consumer, MessageInEnvelopSerializer $serializer, string $queueName) |
||
40 | |||
41 | public function publish($message) |
||
49 | |||
50 | public function consume() |
||
63 | |||
64 | public function __destruct() |
||
68 | |||
69 | /** |
||
70 | * @param string $data |
||
71 | */ |
||
72 | private function doConsume(string $data) |
||
79 | } |
||
80 |