Class TodoQueueStore

Represents a base for entities that store queue data

Inheritance
System.Object
DisposableObject
ApplicationComponent
TodoQueueStore
MongoTodoQueueStore
Implements
System.IDisposable
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
Namespace: Azos.Sky.Workers.Server.Queue
Assembly: Azos.Sky.dll
Syntax
public abstract class TodoQueueStore : ApplicationComponent, IDisposable, IApplicationComponent

Constructors

TodoQueueStore(TodoQueueService, IConfigSectionNode)

Declaration
protected TodoQueueStore(TodoQueueService director, IConfigSectionNode node)
Parameters
Type Name Description
TodoQueueService director
IConfigSectionNode node

Properties

ComponentLogTopic

Declaration
public override string ComponentLogTopic { get; }
Property Value
Type Description
System.String
Overrides

QueueService

References service that this store is under

Declaration
public TodoQueueService QueueService { get; }
Property Value
Type Description
TodoQueueService

Methods

BeginTransaction(TodoQueue)

Declaration
public abstract object BeginTransaction(TodoQueue queue)
Parameters
Type Name Description
TodoQueue queue
Returns
Type Description
System.Object

CommitTransaction(TodoQueue, Object)

Declaration
public abstract void CommitTransaction(TodoQueue queue, object transaction)
Parameters
Type Name Description
TodoQueue queue
System.Object transaction

Complete(TodoQueue, TodoFrame, Exception, Object)

Declaration
public abstract void Complete(TodoQueue queue, TodoFrame todo, Exception error = null, object transaction = null)
Parameters
Type Name Description
TodoQueue queue
TodoFrame todo
System.Exception error
System.Object transaction

Fetch(TodoQueue, DateTime)

Declaration
public abstract IEnumerable<TodoFrame> Fetch(TodoQueue queue, DateTime utcNow)
Parameters
Type Name Description
TodoQueue queue
System.DateTime utcNow
Returns
Type Description
System.Collections.Generic.IEnumerable<TodoFrame>

FetchLatestCorrelated(TodoQueue, String, DateTime)

Declaration
public abstract TodoFrame FetchLatestCorrelated(TodoQueue queue, string correlationKey, DateTime utcStartingFrom)
Parameters
Type Name Description
TodoQueue queue
System.String correlationKey
System.DateTime utcStartingFrom
Returns
Type Description
TodoFrame

GetInboundCapacity(TodoQueue)

Declaration
public abstract int GetInboundCapacity(TodoQueue queue)
Parameters
Type Name Description
TodoQueue queue
Returns
Type Description
System.Int32

Put(TodoQueue, TodoFrame, Object)

Declaration
public abstract void Put(TodoQueue queue, TodoFrame todo, object transaction)
Parameters
Type Name Description
TodoQueue queue
TodoFrame todo
System.Object transaction

RollbackTransaction(TodoQueue, Object)

Declaration
public abstract void RollbackTransaction(TodoQueue queue, object transaction)
Parameters
Type Name Description
TodoQueue queue
System.Object transaction

Update(TodoQueue, Todo, Boolean, Object)

Declaration
public abstract void Update(TodoQueue queue, Todo todo, bool sysOnly, object transaction)
Parameters
Type Name Description
TodoQueue queue
Todo todo
System.Boolean sysOnly
System.Object transaction

Implements

System.IDisposable

Extension Methods