src/DotPulsar/Internal/Abstractions/IConsumerProxy.cs

namespace DotPulsar.Internal.Abstractions
{
    public interface IConsumerProxy : IEnqueue<MessagePackage>, IDequeue<MessagePackage>
    {
        void Active();
        void Inactive();
        void Disconnected();
        void ReachedEndOfTopic();
    }
}