# IPubSubManagerService `IPubSubManagerService` in assembly SanteDB.Core.Api version 3.0.1980.0 ## Summary Represents a pub/sub manager service ## Events | Event | Type | Description | | ------------- | --------------------------------------------------------------------- | -------------------------------------------------------------- | | Subscribing | EventHandler\> | Fired when a subscription is requested, but not yet registered | | Subscribed | EventHandler\> | Fired after a subscription has been registered | | UnSubscribing | EventHandler\> | Fired when an unsubscription is requested | | UnSubscribed | EventHandler\> | Fired when a subscription has been terminated | | Activating | EventHandler\> | Fired after a subscription and channel are activating | | DeActivating | EventHandler\> | Fired after a subscription and channel are deactivating | | Activated | EventHandler\> | Fired after a subscription and channel are activated | | DeActivated | EventHandler\> | Fired after a subscription and channel are deactivated | ## Operations | Operation | Response/Return | Input/Parameter | Description | | --------------------- | ---------------------------------------------- | --------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- | ---------------------------------------------------------------------- | | FindChannel | IQueryResultSet\ | *Expression\>* **filter** | Find an existing channel | | FindSubscription | IQueryResultSet\ | *Expression\>* **filter** | Find an existing subscription | | FindChannel | IEnumerable\ |

Expression\> filter
Int32 offset
Int32 count
Int32& totalResults

| Find an existing channel | | FindSubscription | IEnumerable\ |

Expression\> filter
Int32 offset
Int32 count
Int32& totalResults

| Find an existing subscription | | RegisterChannel | PubSubChannelDefinition |

String name
Type dispatcherFactoryType
Uri endpoint
IDictionary\ settings

| Registers the specified pub-sub channel using the specified dispatcher | | RegisterChannel | PubSubChannelDefinition |

String name
String dispatchFactoryId
Uri endpoint
IDictionary\ settings

| Registers the specified pub-sub channel using the specified dispatcher | | UpdateChannel | PubSubChannelDefinition |

Guid key
String name
Uri endpoint
IDictionary\ settings

| Updates the specified pub-sub channel | | RegisterSubscription | PubSubSubscriptionDefinition |

String name
String description
PubSubEventType events
Expression\> filter
Guid channelId
String supportAddress
Nullable\ notBefore
Nullable\ 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\ notBefore
Nullable\ notAfter

| Register a new subscription for the specified type | | UpdateSubscription | PubSubSubscriptionDefinition |

Guid key
String name
String description
PubSubEventType events
String hdsiFilter
String supportAddress
Nullable\ notBefore
Nullable\ 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 ```markup ...
... ... ``` ### ADO.NET Pub/Sub Subscription Manager - (SanteDB.Persistence.PubSub.ADO) Represents a pub/sub manager which stores definitions in a database #### Service Registration ```markup ...
... ... ``` ## Example Implementation ```csharp /// Example Implementation using SanteDB.Core.PubSub; /// Other usings here public class MyPubSubManagerService : SanteDB.Core.PubSub.IPubSubManagerService { public String ServiceName => "My own IPubSubManagerService service"; /// /// Fired when a subscription is requested, but not yet registered /// public event EventHandler> Subscribing; /// /// Fired after a subscription has been registered /// public event EventHandler> Subscribed; /// /// Fired when an unsubscription is requested /// public event EventHandler> UnSubscribing; /// /// Fired when a subscription has been terminated /// public event EventHandler> UnSubscribed; /// /// Fired after a subscription and channel are activating /// public event EventHandler> Activating; /// /// Fired after a subscription and channel are deactivating /// public event EventHandler> DeActivating; /// /// Fired after a subscription and channel are activated /// public event EventHandler> Activated; /// /// Fired after a subscription and channel are deactivated /// public event EventHandler> DeActivated; /// /// Find an existing channel /// public IQueryResultSet FindChannel(Expression> filter){ throw new System.NotImplementedException(); } /// /// Find an existing subscription /// public IQueryResultSet FindSubscription(Expression> filter){ throw new System.NotImplementedException(); } /// /// Find an existing channel /// public IEnumerable FindChannel(Expression> filter,Int32 offset,Int32 count,Int32& totalResults){ throw new System.NotImplementedException(); } /// /// Find an existing subscription /// public IEnumerable FindSubscription(Expression> filter,Int32 offset,Int32 count,Int32& totalResults){ throw new System.NotImplementedException(); } /// /// Registers the specified pub-sub channel using the specified dispatcher /// public PubSubChannelDefinition RegisterChannel(String name,Type dispatcherFactoryType,Uri endpoint,IDictionary settings){ throw new System.NotImplementedException(); } /// /// Registers the specified pub-sub channel using the specified dispatcher /// public PubSubChannelDefinition RegisterChannel(String name,String dispatchFactoryId,Uri endpoint,IDictionary settings){ throw new System.NotImplementedException(); } /// /// Updates the specified pub-sub channel /// public PubSubChannelDefinition UpdateChannel(Guid key,String name,Uri endpoint,IDictionary settings){ throw new System.NotImplementedException(); } /// /// Register a new subscription for the specified type /// public PubSubSubscriptionDefinition RegisterSubscription(String name,String description,PubSubEventType events,Expression> filter,Guid channelId,String supportAddress,Nullable notBefore,Nullable notAfter){ throw new System.NotImplementedException(); } /// /// Register a new subscription for the specified type /// public PubSubSubscriptionDefinition RegisterSubscription(Type modelType,String name,String description,PubSubEventType events,String hdsiFilter,Guid channelId,String supportAddress,Nullable notBefore,Nullable notAfter){ throw new System.NotImplementedException(); } /// /// Update subscription data /// public PubSubSubscriptionDefinition UpdateSubscription(Guid key,String name,String description,PubSubEventType events,String hdsiFilter,String supportAddress,Nullable notBefore,Nullable notAfter){ throw new System.NotImplementedException(); } /// /// Activate a subscription /// public PubSubSubscriptionDefinition ActivateSubscription(Guid key,Boolean isActive){ throw new System.NotImplementedException(); } /// /// Gets the subscription information /// public PubSubSubscriptionDefinition GetSubscription(Guid id){ throw new System.NotImplementedException(); } /// /// Gets the channel information /// public PubSubChannelDefinition GetChannel(Guid id){ throw new System.NotImplementedException(); } /// /// Removes the specified channel and all related subscriptions /// public PubSubChannelDefinition RemoveChannel(Guid id){ throw new System.NotImplementedException(); } /// /// Removes the subscription /// public PubSubSubscriptionDefinition RemoveSubscription(Guid id){ throw new System.NotImplementedException(); } /// /// Get subscription by its name /// public PubSubSubscriptionDefinition GetSubscriptionByName(String name){ throw new System.NotImplementedException(); } } ``` ## References * [IPubSubManagerService C# Documentation](http://santesuite.org/assets/doc/net/html/T_SanteDB_Core_PubSub_IPubSubManagerService.htm) * [UpstreamPubSubManager C# Documentation](http://santesuite.org/assets/doc/net/html/T_SanteDB_Client_Upstream_Management_UpstreamPubSubManager.htm) * [AdoPubSubManager C# Documentation](http://santesuite.org/assets/doc/net/html/T_SanteDB_Persistence_PubSub_ADO_AdoPubSubManager.htm)