<?php

namespace NoahVet\Reef\RabbitMQ\Task\Sender;

use NoahVet\Reef\RabbitMQ\Producer\Factory\ReefMQProducerFactoryInterface;
use NoahVet\Reef\RabbitMQ\Task\InternalTaskInterface;

class ReefTaskSender implements ReefTaskSenderInterface
{
    public function __construct(
        protected readonly ReefMQProducerFactoryInterface $producerFactory,
    ) {
    }

    #[\Override]
    public function sendTask(InternalTaskInterface $internalTask): void
    {
        $this->producerFactory->getProducer()->publishTask($internalTask);
    }
}
