IPersistedQueueCollection.cs

using System.Threading.Tasks;
using Waher.Runtime.Inventory;
 
namespace Waher.Persistence.Queues
{
    public interface IPersistedQueueCollection : IProcessingSupport<IDatabaseProvider>
    {
        Task<IPersistedQueue> GetQueue(IDatabaseProvider Provider, string QueueName, 
            bool CanBeNull);
 
        Task<string[]> GetQueues(IDatabaseProvider Provider);
    }
}