Class MongoTodoQueueStore

Implements TodoQueueStore using MongoDB

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.MongoDb.dll
Syntax
public sealed class MongoTodoQueueStore : TodoQueueStore, IDisposable, IApplicationComponent

Constructors

MongoTodoQueueStore(TodoQueueService, IConfigSectionNode)

Declaration
public MongoTodoQueueStore(TodoQueueService director, IConfigSectionNode node)
Parameters
Type Name Description
TodoQueueService director
IConfigSectionNode node

Fields

CONFIG_CONVERTER_SECTION

Declaration
public string CONFIG_CONVERTER_SECTION
Field Value
Type Description
System.String

CONFIG_MONGO_SECTION

Declaration
public string CONFIG_MONGO_SECTION
Field Value
Type Description
System.String

DEFAULT_FETCHBY_SIZE

Declaration
public const int DEFAULT_FETCHBY_SIZE = 32
Field Value
Type Description
System.Int32

FLD_TODO_CONTENT

Declaration
public const string FLD_TODO_CONTENT = "c"
Field Value
Type Description
System.String

FLD_TODO_CORRELATIONKEY

Declaration
public const string FLD_TODO_CORRELATIONKEY = "cky"
Field Value
Type Description
System.String

FLD_TODO_CREATETIMESTAMP

Declaration
public const string FLD_TODO_CREATETIMESTAMP = "cts"
Field Value
Type Description
System.String

FLD_TODO_PARALLELKEY

Declaration
public const string FLD_TODO_PARALLELKEY = "plk"
Field Value
Type Description
System.String

FLD_TODO_PRIORITY

Declaration
public const string FLD_TODO_PRIORITY = "pri"
Field Value
Type Description
System.String

FLD_TODO_SERIALIZER

Declaration
public const string FLD_TODO_SERIALIZER = "sr"
Field Value
Type Description
System.String

FLD_TODO_SHARDINGKEY

Declaration
public const string FLD_TODO_SHARDINGKEY = "sk"
Field Value
Type Description
System.String

FLD_TODO_STARTDATE

Declaration
public const string FLD_TODO_STARTDATE = "sd"
Field Value
Type Description
System.String

FLD_TODO_STATE

Declaration
public const string FLD_TODO_STATE = "st"
Field Value
Type Description
System.String

FLD_TODO_TRIES

Declaration
public const string FLD_TODO_TRIES = "tr"
Field Value
Type Description
System.String

FLD_TODO_TYPE

Declaration
public const string FLD_TODO_TYPE = "t"
Field Value
Type Description
System.String

FULL_BATCH_SIZE

Declaration
public const int FULL_BATCH_SIZE = 1024
Field Value
Type Description
System.Int32

MAX_FETCHBY_SIZE

Declaration
public const int MAX_FETCHBY_SIZE = 4096
Field Value
Type Description
System.Int32

Properties

FetchBy

Declaration
[Config(Default = 32)]
public int FetchBy { get; }
Property Value
Type Description
System.Int32

Methods

BeginTransaction(TodoQueue)

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

CommitTransaction(TodoQueue, Object)

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

Complete(TodoQueue, TodoFrame, Exception, Object)

Declaration
public override 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
Overrides

Destructor()

Declaration
protected override void Destructor()
Overrides

Fetch(TodoQueue, DateTime)

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

FetchLatestCorrelated(TodoQueue, String, DateTime)

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

GetInboundCapacity(TodoQueue)

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

Put(TodoQueue, TodoFrame, Object)

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

RollbackTransaction(TodoQueue, Object)

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

Update(TodoQueue, Todo, Boolean, Object)

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

Implements

System.IDisposable

Extension Methods