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<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

Operation	Response/Return	Input/Parameter	Description
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

...
<section xsi:type="ApplicationServiceContextConfigurationSection" threadPoolSize="4">
	<serviceProviders>
		...
		<add type="SanteDB.Client.Upstream.Management.UpstreamPubSubManager, SanteDB.Client, Version=3.0.1980.0, Culture=neutral, PublicKeyToken=null" />
		...
	</serviceProviders>

ADO.NET Pub/Sub Subscription Manager - (SanteDB.Persistence.PubSub.ADO)

Represents a pub/sub manager which stores definitions in a database

Service Registration

...
<section xsi:type="ApplicationServiceContextConfigurationSection" threadPoolSize="4">
	<serviceProviders>
		...
		<add type="SanteDB.Persistence.PubSub.ADO.AdoPubSubManager, SanteDB.Persistence.PubSub.ADO, Version=3.0.1980.0, Culture=neutral, PublicKeyToken=null" />
		...
	</serviceProviders>

Example Implementation

/// Example Implementation
using SanteDB.Core.PubSub;
/// Other usings here
public class MyPubSubManagerService : SanteDB.Core.PubSub.IPubSubManagerService { 
	public String ServiceName => "My own IPubSubManagerService service";
	/// <summary>
	/// Fired when a subscription is requested, but not yet registered
	/// </summary>
	public event EventHandler<DataPersistingEventArgs<PubSubSubscriptionDefinition>> Subscribing;
	/// <summary>
	/// Fired after a subscription has been registered
	/// </summary>
	public event EventHandler<DataPersistedEventArgs<PubSubSubscriptionDefinition>> Subscribed;
	/// <summary>
	/// Fired when an unsubscription is requested
	/// </summary>
	public event EventHandler<DataPersistingEventArgs<PubSubSubscriptionDefinition>> UnSubscribing;
	/// <summary>
	/// Fired when a subscription has been terminated
	/// </summary>
	public event EventHandler<DataPersistedEventArgs<PubSubSubscriptionDefinition>> UnSubscribed;
	/// <summary>
	/// Fired after a subscription and channel are activating
	/// </summary>
	public event EventHandler<DataPersistingEventArgs<PubSubSubscriptionDefinition>> Activating;
	/// <summary>
	/// Fired after a subscription and channel are deactivating
	/// </summary>
	public event EventHandler<DataPersistingEventArgs<PubSubSubscriptionDefinition>> DeActivating;
	/// <summary>
	/// Fired after a subscription and channel are activated
	/// </summary>
	public event EventHandler<DataPersistedEventArgs<PubSubSubscriptionDefinition>> Activated;
	/// <summary>
	/// Fired after a subscription and channel are deactivated
	/// </summary>
	public event EventHandler<DataPersistedEventArgs<PubSubSubscriptionDefinition>> DeActivated;
	/// <summary>
	/// Find an existing channel
	/// </summary>
	public IQueryResultSet<PubSubChannelDefinition> FindChannel(Expression<Func<PubSubChannelDefinition,Boolean>> filter){
		throw new System.NotImplementedException();
	}
	/// <summary>
	/// Find an existing subscription
	/// </summary>
	public IQueryResultSet<PubSubSubscriptionDefinition> FindSubscription(Expression<Func<PubSubSubscriptionDefinition,Boolean>> filter){
		throw new System.NotImplementedException();
	}
	/// <summary>
	/// Find an existing channel
	/// </summary>
	public IEnumerable<PubSubChannelDefinition> FindChannel(Expression<Func<PubSubChannelDefinition,Boolean>> filter,Int32 offset,Int32 count,Int32& totalResults){
		throw new System.NotImplementedException();
	}
	/// <summary>
	/// Find an existing subscription
	/// </summary>
	public IEnumerable<PubSubSubscriptionDefinition> FindSubscription(Expression<Func<PubSubSubscriptionDefinition,Boolean>> filter,Int32 offset,Int32 count,Int32& totalResults){
		throw new System.NotImplementedException();
	}
	/// <summary>
	/// Registers the specified pub-sub channel using the specified dispatcher
	/// </summary>
	public PubSubChannelDefinition RegisterChannel(String name,Type dispatcherFactoryType,Uri endpoint,IDictionary<String,String> settings){
		throw new System.NotImplementedException();
	}
	/// <summary>
	/// Registers the specified pub-sub channel using the specified dispatcher
	/// </summary>
	public PubSubChannelDefinition RegisterChannel(String name,String dispatchFactoryId,Uri endpoint,IDictionary<String,String> settings){
		throw new System.NotImplementedException();
	}
	/// <summary>
	/// Updates the specified pub-sub channel
	/// </summary>
	public PubSubChannelDefinition UpdateChannel(Guid key,String name,Uri endpoint,IDictionary<String,String> settings){
		throw new System.NotImplementedException();
	}
	/// <summary>
	/// Register a new subscription for the specified type
	/// </summary>
	public PubSubSubscriptionDefinition RegisterSubscription<TModel>(String name,String description,PubSubEventType events,Expression<Func<TModel,Boolean>> filter,Guid channelId,String supportAddress,Nullable<DateTimeOffset> notBefore,Nullable<DateTimeOffset> notAfter){
		throw new System.NotImplementedException();
	}
	/// <summary>
	/// Register a new subscription for the specified type
	/// </summary>
	public PubSubSubscriptionDefinition RegisterSubscription(Type modelType,String name,String description,PubSubEventType events,String hdsiFilter,Guid channelId,String supportAddress,Nullable<DateTimeOffset> notBefore,Nullable<DateTimeOffset> notAfter){
		throw new System.NotImplementedException();
	}
	/// <summary>
	/// Update subscription data
	/// </summary>
	public PubSubSubscriptionDefinition UpdateSubscription(Guid key,String name,String description,PubSubEventType events,String hdsiFilter,String supportAddress,Nullable<DateTimeOffset> notBefore,Nullable<DateTimeOffset> notAfter){
		throw new System.NotImplementedException();
	}
	/// <summary>
	/// Activate a subscription
	/// </summary>
	public PubSubSubscriptionDefinition ActivateSubscription(Guid key,Boolean isActive){
		throw new System.NotImplementedException();
	}
	/// <summary>
	/// Gets the subscription information
	/// </summary>
	public PubSubSubscriptionDefinition GetSubscription(Guid id){
		throw new System.NotImplementedException();
	}
	/// <summary>
	/// Gets the channel information
	/// </summary>
	public PubSubChannelDefinition GetChannel(Guid id){
		throw new System.NotImplementedException();
	}
	/// <summary>
	/// Removes the specified channel and all related subscriptions
	/// </summary>
	public PubSubChannelDefinition RemoveChannel(Guid id){
		throw new System.NotImplementedException();
	}
	/// <summary>
	/// Removes the subscription
	/// </summary>
	public PubSubSubscriptionDefinition RemoveSubscription(Guid id){
		throw new System.NotImplementedException();
	}
	/// <summary>
	/// Get subscription by its name
	/// </summary>
	public PubSubSubscriptionDefinition GetSubscriptionByName(String name){
		throw new System.NotImplementedException();
	}
}

References

• IPubSubManagerService C# Documentation

• UpstreamPubSubManager C# Documentation

• AdoPubSubManager C# Documentation