IPubSubManagerService
IPubSubManagerService
in assembly SanteDB.Core.Api version 3.0.1980.0
Summary
Represents a pub/sub manager service
Events
Subscribing
EventHandler<DataPersistingEventArgs<PubSubSubscriptionDefinition>>
Fired when a subscription is requested, but not yet registered
Subscribed
EventHandler<DataPersistedEventArgs<PubSubSubscriptionDefinition>>
Fired after a subscription has been registered
UnSubscribing
EventHandler<DataPersistingEventArgs<PubSubSubscriptionDefinition>>
Fired when an unsubscription is requested
UnSubscribed
EventHandler<DataPersistedEventArgs<PubSubSubscriptionDefinition>>
Fired when a subscription has been terminated
Activating
EventHandler<DataPersistingEventArgs<PubSubSubscriptionDefinition>>
Fired after a subscription and channel are activating
DeActivating
EventHandler<DataPersistingEventArgs<PubSubSubscriptionDefinition>>
Fired after a subscription and channel are deactivating
Activated
EventHandler<DataPersistedEventArgs<PubSubSubscriptionDefinition>>
Fired after a subscription and channel are activated
DeActivated
EventHandler<DataPersistedEventArgs<PubSubSubscriptionDefinition>>
Fired after a subscription and channel are deactivated
Operations
FindChannel
IQueryResultSet<PubSubChannelDefinition>
Expression<Func<PubSubChannelDefinition,Boolean>> filter
Find an existing channel
FindSubscription
IQueryResultSet<PubSubSubscriptionDefinition>
Expression<Func<PubSubSubscriptionDefinition,Boolean>> filter
Find an existing subscription
FindChannel
IEnumerable<PubSubChannelDefinition>
Expression<Func<PubSubChannelDefinition,Boolean>> filter Int32 offset Int32 count Int32& totalResults
Find an existing channel
FindSubscription
IEnumerable<PubSubSubscriptionDefinition>
Expression<Func<PubSubSubscriptionDefinition,Boolean>> filter Int32 offset Int32 count Int32& totalResults
Find an existing subscription
RegisterChannel
PubSubChannelDefinition
String name Type dispatcherFactoryType Uri endpoint IDictionary<String,String> settings
Registers the specified pub-sub channel using the specified dispatcher
RegisterChannel
PubSubChannelDefinition
String name String dispatchFactoryId Uri endpoint IDictionary<String,String> settings
Registers the specified pub-sub channel using the specified dispatcher
UpdateChannel
PubSubChannelDefinition
Guid key String name Uri endpoint IDictionary<String,String> settings
Updates the specified pub-sub channel
RegisterSubscription
PubSubSubscriptionDefinition
String name String description PubSubEventType events Expression<Func<TModel,Boolean>> filter Guid channelId String supportAddress Nullable<DateTimeOffset> notBefore Nullable<DateTimeOffset> notAfter
Register a new subscription for the specified type
RegisterSubscription
PubSubSubscriptionDefinition
Type modelType String name String description PubSubEventType events String hdsiFilter Guid channelId String supportAddress Nullable<DateTimeOffset> notBefore Nullable<DateTimeOffset> notAfter
Register a new subscription for the specified type
UpdateSubscription
PubSubSubscriptionDefinition
Guid key String name String description PubSubEventType events String hdsiFilter String supportAddress Nullable<DateTimeOffset> notBefore Nullable<DateTimeOffset> notAfter
Update subscription data
ActivateSubscription
PubSubSubscriptionDefinition
Guid key Boolean isActive
Activate a subscription
GetSubscription
PubSubSubscriptionDefinition
Guid id
Gets the subscription information
GetChannel
PubSubChannelDefinition
Guid id
Gets the channel information
RemoveChannel
PubSubChannelDefinition
Guid id
Removes the specified channel and all related subscriptions
RemoveSubscription
PubSubSubscriptionDefinition
Guid id
Removes the subscription
GetSubscriptionByName
PubSubSubscriptionDefinition
String name
Get subscription by its name
Implementations
UpstreamPubSubManager - (SanteDB.Client)
Upstream publish and subscribe
Service Registration
ADO.NET Pub/Sub Subscription Manager - (SanteDB.Persistence.PubSub.ADO)
Represents a pub/sub manager which stores definitions in a database
Service Registration
Example Implementation
References
Last updated