Class ProcessStore

Represents a base for entities that store queue data

Inheritance
System.Object
DisposableObject
ApplicationComponent
ProcessStore
MongoProcessStore
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
Assembly: Azos.Sky.dll
Syntax
public abstract class ProcessStore : ApplicationComponent, IDisposable, IApplicationComponent

Constructors

ProcessStore(ProcessControllerService, IConfigSectionNode)

Declaration
protected ProcessStore(ProcessControllerService director, IConfigSectionNode node)
Parameters
Type Name Description
ProcessControllerService director
IConfigSectionNode node

Properties

ComponentLogTopic

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

ProcessController

References service that this store is under

Declaration
public ProcessControllerService ProcessController { get; }
Property Value
Type Description
ProcessControllerService

Methods

BeginTransaction()

Declaration
public abstract object BeginTransaction()
Returns
Type Description
System.Object

CommitTransaction(Object)

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

Delete(ProcessFrame, Object)

Declaration
public abstract void Delete(ProcessFrame frame, object transaction)
Parameters
Type Name Description
ProcessFrame frame
System.Object transaction

GetByPID(PID)

Declaration
public virtual ProcessFrame GetByPID(PID pid)
Parameters
Type Name Description
PID pid
Returns
Type Description
ProcessFrame

List(Int32)

Declaration
public abstract IEnumerable<ProcessDescriptor> List(int processorID)
Parameters
Type Name Description
System.Int32 processorID
Returns
Type Description
System.Collections.Generic.IEnumerable<ProcessDescriptor>

Log(MessageType, String, String, Exception, Nullable<Guid>, String)

Declaration
protected Guid Log(MessageType type, string from, string message, Exception error = null, Guid? relatedMessageID = default(Guid? ), string parameters = null)
Parameters
Type Name Description
MessageType type
System.String from
System.String message
System.Exception error
System.Nullable<System.Guid> relatedMessageID
System.String parameters
Returns
Type Description
System.Guid

Put(ProcessFrame, Object)

Declaration
public abstract void Put(ProcessFrame frame, object transaction)
Parameters
Type Name Description
ProcessFrame frame
System.Object transaction

RollbackTransaction(Object)

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

TryGetByPID(PID, out ProcessFrame)

Declaration
public abstract bool TryGetByPID(PID pid, out ProcessFrame frame)
Parameters
Type Name Description
PID pid
ProcessFrame frame
Returns
Type Description
System.Boolean

Update(ProcessFrame, Boolean, Object)

Declaration
public abstract void Update(ProcessFrame frame, bool sysOnly, object transaction)
Parameters
Type Name Description
ProcessFrame frame
System.Boolean sysOnly
System.Object transaction

Implements

System.IDisposable

Extension Methods