Show / Hide Table of Contents

Class Subscription

Represents a subscription to the CRUD Data. Call Dispose() to terminate the subscription.

Inheritance
System.Object
DisposableObject
ApplicationComponent
SubscriptionAppComponent
Subscription
ErlCRUDSubscription
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 abstract class Subscription : SubscriptionAppComponent, IApplicationComponent, IDisposable, IExternallyParameterized, INamed

Constructors

Subscription(ICRUDSubscriptionStoreImplementation, String, Query, Mailbox, Object)

Declaration
protected Subscription(ICRUDSubscriptionStoreImplementation store, string name, Query query, Mailbox mailbox, object correlate)
Parameters
Type Name Description
ICRUDSubscriptionStoreImplementation store
System.String name
Query query
Mailbox mailbox
System.Object correlate

Properties

Correlate

Allows to attach arbtrary bject for correlation

Declaration
public object Correlate { get; set; }
Property Value
Type Description
System.Object

InvalidSubscriptionException

If this property is not null then this subscription is !IsValid

Declaration
public InvalidSubscriptionRequestException InvalidSubscriptionException { get; }
Property Value
Type Description
InvalidSubscriptionRequestException

IsLoaded

Declaration
public bool IsLoaded { get; }
Property Value
Type Description
System.Boolean

IsValid

Returns false when this subscription experienced InvalidSubscriptionException

Declaration
public bool IsValid { get; }
Property Value
Type Description
System.Boolean

Mailbox

Declaration
public Mailbox Mailbox { get; }
Property Value
Type Description
Mailbox

Name

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

Query

Declaration
public Query Query { get; }
Property Value
Type Description
Query

Store

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

Methods

Destructor()

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

HasLoaded()

Call after subscription has been initialized

Declaration
protected void HasLoaded()

Invalidate(InvalidSubscriptionRequestException)

Called by descendants to invalidate this subscription

Declaration
protected void Invalidate(InvalidSubscriptionRequestException error)
Parameters
Type Name Description
InvalidSubscriptionRequestException error

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