# 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) --- # Agent Instructions: Querying This Documentation If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question. Perform an HTTP GET request on the current page URL with the `ask` query parameter: ``` GET https://help.santesuite.org/developers/server-plugins/implementing-.net-features/service-definitions/ipubsubmanagerservice.md?ask= ``` The question should be specific, self-contained, and written in natural language. The response will contain a direct answer to the question and relevant excerpts and sources from the documentation. Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.