dCDR Subscription Execution Provider

ISubscriptionExecutor in assembly SanteDB.Core.Api version 2.1.151.0

Summary

Contract which defines a dCDR subscription executor

Description

The subscription executor is responsible for the translation of a dCDR SubscriptionDefinition from the ISubscriptionRepository to the appropriate database technology. The subscription executor gathers any new records requested by the dCDR and prepares them for download by the dCDR.

Events

Event	Type	Description
Executed	EventHandler<QueryResultEventArgs<IdentifiedData>>	Occurs after a subscription has been executed, and allows subscribers to modify the data being sent back to the dCDR
Executing	EventHandler<QueryRequestEventArgs<IdentifiedData>>	Occurs prior to a subscription being executed, and allows subscribers to modify the query being executed.

Operations

Operation	Response/Return	Input/Parameter	Description
Execute	IEnumerable<Object>	Guid subscriptionKey NameValueCollection parameters Int32 offset Nullable<Int32> count Int32& totalResults Guid queryId	Executes the identified subscription agianst the persistence layer.
Execute	IEnumerable<Object>	SubscriptionDefinition subscription NameValueCollection parameters Int32 offset Nullable<Int32> count Int32& totalResults Guid queryId	Executes the identified subscription agianst the persistence layer.

Implementations

ADO.NET Subscription Executor - (SanteDB.Persistence.Data.ADO)

An implementation of the ISubscriptionExecutor which uses an ADO persistence layer

Service Registration

...
<section xsi:type="ApplicationServiceContextConfigurationSection" threadPoolSize="4">
	<serviceProviders>
		...
		<add type="SanteDB.Persistence.Data.ADO.Services.AdoSubscriptionExecutor, SanteDB.Persistence.Data.ADO, Version=2.1.151.0, Culture=neutral, PublicKeyToken=null" />
		...
	</serviceProviders>

Example Implementation

/// Example Implementation
using SanteDB.Core.Services;
/// Other usings here
public class MySubscriptionExecutor : SanteDB.Core.Services.ISubscriptionExecutor { 
	public String ServiceName => "My own ISubscriptionExecutor service";
	/// <summary>
	/// Occurs after a subscription has been executed, and allows subscribers to modify the data being            sent back to the dCDR
	/// </summary>
	public event EventHandler<QueryResultEventArgs<IdentifiedData>> Executed;
	/// <summary>
	/// Occurs prior to a subscription being executed, and allows subscribers to modify the query being            executed.
	/// </summary>
	public event EventHandler<QueryRequestEventArgs<IdentifiedData>> Executing;
	/// <summary>
	/// Executes the identified subscription agianst the persistence layer.
	/// </summary>
	public IEnumerable<Object> Execute(Guid subscriptionKey,NameValueCollection parameters,Int32 offset,Nullable<Int32> count,Int32& totalResults,Guid queryId){
		throw new System.NotImplementedException();
	}
	/// <summary>
	/// Executes the identified subscription agianst the persistence layer.
	/// </summary>
	public IEnumerable<Object> Execute(SubscriptionDefinition subscription,NameValueCollection parameters,Int32 offset,Nullable<Int32> count,Int32& totalResults,Guid queryId){
		throw new System.NotImplementedException();
	}
}

References

• ISubscriptionExecutor C# Documentation

• AdoSubscriptionExecutor C# Documentation