using Pole.Core;
using Pole.Core.EventBus;
using System.Threading.Tasks;

namespace Pole.EventBus.RabbitMQ
{
    public class RabbitProducer : IProducer
    {
        readonly RabbitEventBus publisher;
        readonly IRabbitMQClient rabbitMQClient;
        public RabbitProducer(
            IRabbitMQClient rabbitMQClient,
            RabbitEventBus publisher)
        {
            this.publisher = publisher;
            this.rabbitMQClient = rabbitMQClient;
        }
        public ValueTask Publish(byte[] bytes)
        {
            using var channel = rabbitMQClient.PullChannel();
            channel.Publish(bytes, publisher.Exchange, string.Empty, publisher.Persistent);
            return Consts.ValueTaskDone;
        }
    }
}