Click or drag to resize

PubSubBroker Class

An implementation of the IDaemonService which is responsible for monitoring the IPubSubManagerService for new subscription events
Inheritance Hierarchy
SystemObject
  SanteDB.Core.PubSub.BrokerPubSubBroker

Namespace: SanteDB.Core.PubSub.Broker
Assembly: SanteDB.Core.Api (in SanteDB.Core.Api.dll) Version: 3.0.2081-alpha+b4ae72647f2cc271f89142f76fff26ad69e00f5a
Syntax
public class PubSubBroker : IDaemonService, 
	IServiceImplementation, IDisposable

The PubSubBroker type exposes the following members.

Constructors
 NameDescription
Public methodPubSubBroker Create a new pub-sub broker
Top
Properties
 NameDescription
Public propertyIsRunning True if the broker is running
Public propertyServiceName Gets the service name
Top
Methods
 NameDescription
Public methodDispose Dispose of the listeners
Public methodEqualsDetermines whether the specified object is equal to the current object.
(Inherited from Object)
Protected methodFinalizeAllows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection.
(Inherited from Object)
Protected methodGetDispatcher Get all dispatchers and subscriptions
Public methodGetHashCodeServes as the default hash function.
(Inherited from Object)
Public methodGetTypeGets the Type of the current instance.
(Inherited from Object)
Protected methodMemberwiseCloneCreates a shallow copy of the current Object.
(Inherited from Object)
Public methodStart Start the service
Public methodStop Stop the service
Public methodToStringReturns a string that represents the current object.
(Inherited from Object)
Top
Events
 NameDescription
Public eventStarted The service is started
Public eventStarting The service is starting
Public eventStopped The service is stopped
Public eventStopping The service is stopping
Top
Fields
 NameDescription
Public fieldStatic memberQueueName Queue name
Top
Extension Methods
 NameDescription
Public Extension MethodConvertTReturn The purpose of this method is to convert object me to TReturn. Why? Because if you have an instance of Act that actually needs to be a SubstanceAdministration we can't just cast so we have to copy.
(Defined by ExtensionMethods)
Public Extension MethodWithControl With control parameter is used as a wrapper for _ parameters
(Defined by QueryFilterExtensions)
Top
Remarks

The Pub/Sub broker is the central daemon which is responsible for coordinating outbound notifications based on filters established by subscribers. The broker:

  1. Listens to the Subscribe event on the IPubSubManagerService and creates a callback for the data event
  2. Enqueues any new data to the IDispatcherQueueManagerService for sending to outbound recipients
  3. When a IDispatcherQueueManagerService message is enqueued, loads the appropriate IPubSubDispatcherFactory and publishes the notification
See Also