Uses of Interface
com.caplin.datasource.Peer
Package
Description
The Channel package consists of interfaces allowing creation and maintenance of
Channel
s that
provide a bi-directional communication mechanism between StreamLink clients and DataSource applicationsDefines the methods of providing and publishing data that are used by DataSource for Java.
Defines the interfaces and classes that are used by a Java DataSource application when it needs
to subscribe to data provided by another DataSource application.
-
Uses of Peer in com.caplin.datasource
-
Uses of Peer in com.caplin.datasource.channel
-
Uses of Peer in com.caplin.datasource.publisher
Modifier and TypeMethodDescriptionDiscardEvent.getPeer()
Gets thePeer
that is discarding the subject.RequestEvent.getPeer()
Gets thePeer
that is requesting the subject.Modifier and TypeMethodDescriptionvoid
BroadcastPublisher.publishSubjectErrorEvent
(Peer peer, SubjectErrorEvent subjectErrorEvent) Publishes to the specified peer subscribed to a subject an event detailing an error in the subscription for that subject.void
BroadcastPublisher.publishSubjectStatusEvent
(Peer peer, SubjectStatusEvent subjectStatusEvent) Publishes to the specified peer an event about the change in status of a subject.void
BroadcastPublisher.publishToPeer
(Peer peer, Message message) -
Uses of Peer in com.caplin.datasource.subscription
Modifier and TypeMethodDescriptionvoid
BaseSubscriptionListener.containerUpdated
(Subscription subscription, Peer peer, ContainerMessage containerMessage) void
SubscriptionListener.containerUpdated
(Subscription subscription, Peer peer, ContainerMessage message) Called when a container update is received.void
BaseSubscriptionListener.genericMessageUpdated
(Subscription subscription, Peer peer, GenericMessage message) void
SubscriptionListener.genericMessageUpdated
(Subscription subscription, Peer peer, GenericMessage message) Called when an update to generic message data is received.void
BaseSubscriptionListener.jsonUpdated
(Subscription subscription, Peer peer, JsonMessage message) void
SubscriptionListener.jsonUpdated
(Subscription subscription, Peer peer, JsonMessage message) Called when an update to json message data is received.void
BaseSubscriptionListener.newsUpdated
(Subscription subscription, Peer peer, NewsMessage newsMessage) void
SubscriptionListener.newsUpdated
(Subscription subscription, Peer peer, NewsMessage message) Called when a news headline update is received.void
BaseSubscriptionListener.pageUpdated
(Subscription subscription, Peer peer, PageMessage pageMessage) void
SubscriptionListener.pageUpdated
(Subscription subscription, Peer peer, PageMessage message) Called when a page update is received.void
BaseSubscriptionListener.permissionUpdated
(Subscription subscription, Peer peer, PermissionMessage permissionMessage) void
SubscriptionListener.permissionUpdated
(Subscription subscription, Peer peer, PermissionMessage message) Called when when a permission update is received.void
BaseSubscriptionListener.recordType2Updated
(Subscription subscription, Peer peer, RecordType2Message recordType2Message) void
SubscriptionListener.recordType2Updated
(Subscription subscription, Peer peer, RecordType2Message message) Called when an update to type 2 data in a record is received.void
BaseSubscriptionListener.recordType3Updated
(Subscription subscription, Peer peer, RecordType3Message recordType3Message) void
SubscriptionListener.recordType3Updated
(Subscription subscription, Peer peer, RecordType3Message message) Called when an update to type 3 data in a record is received.void
BaseSubscriptionListener.recordUpdated
(Subscription subscription, Peer peer, RecordMessage recordMessage) void
SubscriptionListener.recordUpdated
(Subscription subscription, Peer peer, RecordMessage message) Called when an update to type 1 data in a record is received.void
BaseSubscriptionListener.storyUpdated
(Subscription subscription, Peer peer, StoryMessage storyMessage) void
SubscriptionListener.storyUpdated
(Subscription subscription, Peer peer, StoryMessage message) Called when a story update is received.void
BaseSubscriptionListener.subjectErrorReceived
(Subscription subscription, Peer peer, SubjectErrorEvent subjectErrorEvent) void
SubscriptionListener.subjectErrorReceived
(Subscription subscription, Peer peer, SubjectErrorEvent subjectErrorEvent) Called when there is an error in a subscription.void
BaseSubscriptionListener.subjectStatusReceived
(Subscription subscription, Peer peer, SubjectStatusEvent subjectStatusEvent) void
SubscriptionListener.subjectStatusReceived
(Subscription subscription, Peer peer, SubjectStatusEvent subjectStatusEvent) Called when there is a change in the status of a subscription.