20 private $messageQueueConfig;
25 private $queueManagement;
35 $this->messageQueueConfig = $messageQueueConfig;
36 $this->queueManagement = $queueManagement;
42 public function enqueue($topic, array $envelopes)
44 $queueNames = $this->messageQueueConfig->getQueuesByTopic($topic);
45 $messages = array_map(
46 function ($envelope) {
47 return $envelope->getBody();
51 $this->queueManagement->addMessagesToQueues($topic, $messages, $queueNames);
enqueue($topic, array $envelopes)
__construct(MessageQueueConfig $messageQueueConfig, QueueManagement $queueManagement)