IPersistedQueue.cs

using System.Threading.Tasks;
using Waher.Events;
 
namespace Waher.Persistence
{
    public interface IPersistedQueue : IDisposableAsync
    {
        Task<bool> Enqueue(object Item);
 
        Task<bool> Enqueue(object Item, int TimeoutMilliseconds);
 
        Task<object> Dequeue();
 
        Task<object> Dequeue(int TimeoutMilliseconds);
 
        Task<object> TryDequeue();
 
        Task<object> Peek();
 
        Task<int> GetNrDequeuers();
 
        Task<int> GetNrEnqueuers();
 
        Task Clear();
    }
}