DataSource.NET  7.1.29.112283-2b6ad187
Caplin.DataSource.Publisher.IActivePublisher Interface Reference

This implementation of IPublisher sends its associated IDataProvider all requests and the final discard for the subjects defined by the associated INamespace. More...

Inheritance diagram for Caplin.DataSource.Publisher.IActivePublisher:
Caplin.DataSource.Publisher.IPublisher

Public Member Functions

void PublishStatusEventToAllSubjects (IStatusEvent ev)
 Send a status message to all requested subjects. This API can be used to change the status of requested subjects when the status of the IDataProvider changes. More...
 
- Public Member Functions inherited from Caplin.DataSource.Publisher.IPublisher
void PublishInitialMessage (IMessage message)
 Publishes the initial message of the data for a Subject to peers that have just requested (subscribed to) that subject. More...
 
void PublishMappingMessage (IMappingMessage mapping)
 Publishes to all peers subscribed to a subject a message that instructs the remote peer to request an alternate subject in order to satisfy the subscription. More...
 
void PublishSubjectErrorEvent (ISubjectErrorEvent ev)
 Publishes to all peers subscribed to a subject an event detailing an error in the subscription for that subject. Typically an IDataProvider will use this to notify the remote peers that an string they are subscribed to is no longer available. More...
 
void PublishSubjectStatusEvent (ISubjectStatusEvent ev)
 Publishes to all subscribed peers an event about the change in status of a subject. More...
 
void PublishToSubscribedPeers (IMessage message)
 Publishes a message to subscribed peers (that is, the peers that have already received an initial image). More...
 

Additional Inherited Members

- Properties inherited from Caplin.DataSource.Publisher.IPublisher
IMessageFactory MessageFactory [get]
 Gets the IMessageFactory used to create the messages that are published via this publisher. More...
 

Detailed Description

This implementation of IPublisher sends its associated IDataProvider all requests and the final discard for the subjects defined by the associated INamespace.

The IDataProvider implementation must call Caplin.DataSource.Publisher.ISubjectPeerSubscriptions.PublishInitialImage to ensure that each requesting (subscribing) peer receives an initial image. Each call to PublishInitialImage sends the image to all peers that have requested the subject since the previous call to PublishInitialImage.

The IDataProvider implementation is responsible for keeping track of the number of requests received; it must only stop supplying data for a subject when there are no more peers subscribing to that subject.

Member Function Documentation

void Caplin.DataSource.Publisher.IActivePublisher.PublishStatusEventToAllSubjects ( IStatusEvent  ev)

Send a status message to all requested subjects. This API can be used to change the status of requested subjects when the status of the IDataProvider changes.


Generated on Wed Mar 8 2023 19:11:38 for DataSource.NET