Show / Hide Table of Contents

Class Mailbox

Represents CRUD row data recipient

Inheritance
System.Object
DisposableObject
ApplicationComponent
SubscriptionAppComponent
Mailbox
ErlCRUDMailbox
Implements
IApplicationComponent
System.IDisposable
IExternallyParameterized
INamed
Inherited Members
SubscriptionAppComponent.ExternalParameters
SubscriptionAppComponent.ExternalParametersForGroups(String[])
SubscriptionAppComponent.ExternalGetParameter(String, Object, String[])
SubscriptionAppComponent.ExternalSetParameter(String, Object, String[])
ApplicationComponent.AllComponents
ApplicationComponent.GetAppComponentBySID(UInt64)
ApplicationComponent.GetAppComponentByCommonName(String)
ApplicationComponent.ComponentSID
ApplicationComponent.ComponentStartTime
ApplicationComponent.ComponentCommonName
ApplicationComponent.ComponentDirector
DisposableObject.DisposeAndNull<T>(T)
DisposableObject.DisposeStarted
DisposableObject.Disposed
DisposableObject.EnsureObjectNotDisposed()
DisposableObject.Dispose()
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)
System.Object.ToString()
Namespace: NFX.DataAccess.CRUD.Subscriptions
Assembly: NFX.dll
Syntax
public class Mailbox : SubscriptionAppComponent, IApplicationComponent, IDisposable, IExternallyParameterized, INamed

Constructors

Mailbox(ICRUDSubscriptionStoreImplementation, String)

Declaration
protected Mailbox(ICRUDSubscriptionStoreImplementation store, string name)
Parameters
Type Name Description
ICRUDSubscriptionStoreImplementation store
System.String name

Properties

BufferCapacity

Declaration
[ExternalParameter(new string[]{"data"})]
public int BufferCapacity { get; set; }
Property Value
Type Description
System.Int32

Buffered

Returns all buffered data in chronological order

Declaration
public CRUDSubscriptionEvent[] Buffered { get; }
Property Value
Type Description
CRUDSubscriptionEvent[]

BufferedCount

Returns how much is currently buffered

Declaration
public int BufferedCount { get; }
Property Value
Type Description
System.Int32

Name

Declaration
public string Name { get; }
Property Value
Type Description
System.String

Store

Declaration
public ICRUDSubscriptionStore Store { get; }
Property Value
Type Description
ICRUDSubscriptionStore

Subscriptions

Declaration
public IRegistry<Subscription> Subscriptions { get; }
Property Value
Type Description
IRegistry<Subscription>

Methods

Deliver(Subscription, CRUDSubscriptionEvent)

Delivers data to the mailbox. This method is called by subscription

Declaration
public bool Deliver(Subscription subscription, CRUDSubscriptionEvent data)
Parameters
Type Name Description
Subscription subscription
CRUDSubscriptionEvent data
Returns
Type Description
System.Boolean

DeliverError(Subscription, Exception)

Declaration
public bool DeliverError(Subscription subscription, Exception error)
Parameters
Type Name Description
Subscription subscription
System.Exception error
Returns
Type Description
System.Boolean

Destructor()

Declaration
protected override void Destructor()
Overrides
ApplicationComponent.Destructor()

FetchBuffered(Int32, Boolean)

Tries to take the specified number of samples in chronological order

Declaration
public List<CRUDSubscriptionEvent> FetchBuffered(int count, bool keep = false)
Parameters
Type Name Description
System.Int32 count
System.Boolean keep
Returns
Type Description
System.Collections.Generic.List<CRUDSubscriptionEvent>

OnReceipt(Subscription, CRUDSubscriptionEvent, Exception)

Declaration
protected virtual void OnReceipt(Subscription subscription, CRUDSubscriptionEvent data, Exception error)
Parameters
Type Name Description
Subscription subscription
CRUDSubscriptionEvent data
System.Exception error

Events

Receipt

Declaration
public event SubscriptionReceiptEventHandler Receipt
Event Type
Type Description
SubscriptionReceiptEventHandler

Implements

IApplicationComponent
System.IDisposable
IExternallyParameterized
INamed

Extension Methods

MiscUtils.NonNull<T>(T, Func<Exception>, String)
ObjectValueConversion.AsString(Object, String, ConvertErrorHandling)
ObjectValueConversion.AsNonNullOrEmptyString(Object)
ObjectValueConversion.AsLaconicConfig(Object, ConfigSectionNode, String, ConvertErrorHandling)
ObjectValueConversion.AsJSONConfig(Object, ConfigSectionNode, String, ConvertErrorHandling)
ObjectValueConversion.AsXMLConfig(Object, ConfigSectionNode, ConvertErrorHandling)
ObjectValueConversion.AsChar(Object, Char, ConvertErrorHandling)
ObjectValueConversion.AsNullableChar(Object, Nullable<Char>, ConvertErrorHandling)
ObjectValueConversion.AsByte(Object, Byte, ConvertErrorHandling)
ObjectValueConversion.AsNullableByte(Object, Nullable<Byte>, ConvertErrorHandling)
ObjectValueConversion.AsSByte(Object, SByte, ConvertErrorHandling)
ObjectValueConversion.AsNullableSByte(Object, Nullable<SByte>, ConvertErrorHandling)
ObjectValueConversion.AsShort(Object, Int16, ConvertErrorHandling)
ObjectValueConversion.AsNullableShort(Object, Nullable<Int16>, ConvertErrorHandling)
ObjectValueConversion.AsUShort(Object, UInt16, ConvertErrorHandling)
ObjectValueConversion.AsNullableUShort(Object, Nullable<UInt16>, ConvertErrorHandling)
ObjectValueConversion.AsInt(Object, Int32, ConvertErrorHandling)
ObjectValueConversion.AsNullableInt(Object, Nullable<Int32>, ConvertErrorHandling)
ObjectValueConversion.AsUInt(Object, UInt32, ConvertErrorHandling)
ObjectValueConversion.AsNullableUInt(Object, Nullable<UInt32>, ConvertErrorHandling)
ObjectValueConversion.AsLong(Object, Int64, ConvertErrorHandling)
ObjectValueConversion.AsNullableLong(Object, Nullable<Int64>, ConvertErrorHandling)
ObjectValueConversion.AsULong(Object, UInt64, ConvertErrorHandling)
ObjectValueConversion.AsNullableULong(Object, Nullable<UInt64>, ConvertErrorHandling)
ObjectValueConversion.AsDouble(Object, Double, ConvertErrorHandling)
ObjectValueConversion.AsNullableDouble(Object, Nullable<Double>, ConvertErrorHandling)
ObjectValueConversion.AsFloat(Object, Single, ConvertErrorHandling)
ObjectValueConversion.AsNullableFloat(Object, Nullable<Single>, ConvertErrorHandling)
ObjectValueConversion.AsDecimal(Object, Decimal, ConvertErrorHandling)
ObjectValueConversion.AsNullableDecimal(Object, Nullable<Decimal>, ConvertErrorHandling)
ObjectValueConversion.AsBool(Object, Boolean, ConvertErrorHandling)
ObjectValueConversion.AsNullableBool(Object, Nullable<Boolean>, ConvertErrorHandling)
ObjectValueConversion.AsGUID(Object, Guid, ConvertErrorHandling)
ObjectValueConversion.AsNullableGUID(Object, Nullable<Guid>, ConvertErrorHandling)
ObjectValueConversion.AsDateTime(Object)
ObjectValueConversion.AsDateTime(Object, DateTime, ConvertErrorHandling)
ObjectValueConversion.AsNullableDateTime(Object, Nullable<DateTime>, ConvertErrorHandling)
ObjectValueConversion.AsGDID(Object)
ObjectValueConversion.AsGDID(Object, GDID, ConvertErrorHandling)
ObjectValueConversion.AsNullableGDID(Object, Nullable<GDID>, ConvertErrorHandling)
ObjectValueConversion.AsGDIDSymbol(Object)
ObjectValueConversion.AsGDIDSymbol(Object, GDIDSymbol, ConvertErrorHandling)
ObjectValueConversion.AsNullableGDIDSymbol(Object, Nullable<GDIDSymbol>, ConvertErrorHandling)
ObjectValueConversion.AsTimeSpan(Object)
ObjectValueConversion.AsTimeSpan(Object, TimeSpan, ConvertErrorHandling)
ObjectValueConversion.AsNullableTimeSpan(Object, Nullable<TimeSpan>, ConvertErrorHandling)
ObjectValueConversion.AsEnum<TEnum>(Object, TEnum, ConvertErrorHandling)
ObjectValueConversion.AsNullableEnum<TEnum>(Object, Nullable<TEnum>, ConvertErrorHandling)
ObjectValueConversion.AsUri(Object, Uri, ConvertErrorHandling)
JSONExtensions.ToJSON(Object, JSONWritingOptions)
JSONExtensions.ToJSON(Object, TextWriter, JSONWritingOptions)
JSONExtensions.ToJSON(Object, Stream, JSONWritingOptions, Encoding)
ErlObject.ToErlObject(Object)
ErlObject.ToErlObject(Object, ErlTypeOrder, Boolean)
Back to top Copyright © 2006-2018 Agnicore Inc
Generated by DocFX