using System;
using System.Collections.Generic;
using System.Data.Common;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.DTO.PubSub;

namespace GB5Shared.PubSub.OutBox
{
    public interface IOutBox
    {
        Task PublishEventAsync(OutboxDTO OutboxDTO, LoginDTO LoginDTO ,DbTransaction Trans);
        Task PublishPendingEventsAsync(string pubsubName, LoginDTO LoginDTO, int batchSize = 100);
        Task<IEnumerable<dynamic>> GetEventsByCorrelationAsync(string correlationKey, LoginDTO LoginDTO);
    }
}