Interface ICRUDSubscriptionStore

Describes a CRUD store that can send ROW data via an established subscriptions into local recipients. Subscriptions are really stateless, they do not capture the data, however the Recipients do. Recipients can either support pull (caller has to fetch data), or reactive (calling delegate) modes

Inherited Members
System.IDisposable.Dispose()
Namespace: NFX.DataAccess.CRUD.Subscriptions
Assembly: NFX.dll
Syntax
public interface ICRUDSubscriptionStore : IDataStore, IApplicationComponent, IDisposable

Properties

Mailboxes

Returns registry of all mailboxes

Declaration
IRegistry<Mailbox> Mailboxes { get; }
Property Value
Type Description
IRegistry<Mailbox>

Subscriptions

Returns registry of all active subscriptions

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

Methods

OpenMailbox(String)

Returns existing mailbox by name (case-insensitive) or creates a new named mailbox

Declaration
Mailbox OpenMailbox(string name)
Parameters
Type Name Description
System.String name
Returns
Type Description
Mailbox

Subscribe(String, Query, Mailbox, Object)

Subscribes the local recipient to the remote data store by executing a Query. The subscription ends by calling a .Dispose()

Declaration
Subscription Subscribe(string name, Query query, Mailbox recipient, object correlate = null)
Parameters
Type Name Description
System.String name

The store-wide-unique subscription name
Query query

The query that informs the remote store what data to send back
Mailbox recipient

The local Recipient which will receive remote data
System.Object correlate

Adhock correlation object
Returns
Type Description
Subscription

The subscription. It may be ended by calling .Dispose()

Extension Methods