Package com.caplin.motif.datasource

Class SubjectMessagePublisher<T extends SubjectInfo>

java.lang.Object

com.caplin.motif.datasource.SubjectMessagePublisher<T>

Direct Known Subclasses:

FXQuotePublisher, LiquidityInformationPublisher, PrecisionInformationPublisher, SingleValuePublisher

public class SubjectMessagePublisher<T extends SubjectInfo>
extends Object

Constructor Summary

Constructors

Constructor	Description
SubjectMessagePublisher(CachedPublisher publisher, boolean useGenerics)

Method Summary

Modifier and Type	Method	Description
void	publishMessage(SubjectMessage<T> subjectMessage)
void	publishMessage(T subjectInfo, Message message)
void	ratesUnavailable()
void	sendErrorEvent(SubjectInfo subjectInfo, com.caplin.datasource.SubjectError subjectError)
void	sendMapping(SubjectInfo from, SubjectInfo to)
void	sendMapping(SubjectInfo from, String to)
void	sendNotFound(SubjectInfo info)
void	sendNotStale(SubjectInfo info)
void	sendStale(SubjectInfo info)
void	sendStale(SubjectInfo info, String message)
void	sendSubjectStatusEvent(SubjectInfo info, com.caplin.datasource.SubjectStatus subjectStatus, String message)
void	sendSubscribeFail(SubjectInfo info)
void	sendSubscribeFail(String subject)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SubjectMessagePublisher

public SubjectMessagePublisher(CachedPublisher publisher,
                               boolean useGenerics)

Method Detail

publishMessage

public void publishMessage(T subjectInfo,
                           Message message)

publishMessage

public void publishMessage(SubjectMessage<T> subjectMessage)

sendSubscribeFail

public void sendSubscribeFail(SubjectInfo info)

sendSubscribeFail

public void sendSubscribeFail(String subject)

sendStale

public void sendStale(SubjectInfo info)

sendStale

public void sendStale(SubjectInfo info,
                      String message)

sendNotStale

public void sendNotStale(SubjectInfo info)

sendSubjectStatusEvent

public void sendSubjectStatusEvent(SubjectInfo info,
                                   com.caplin.datasource.SubjectStatus subjectStatus,
                                   String message)

sendNotFound

public void sendNotFound(SubjectInfo info)

sendMapping

public void sendMapping(SubjectInfo from,
                        SubjectInfo to)

sendMapping

public void sendMapping(SubjectInfo from,
                        String to)

ratesUnavailable

public void ratesUnavailable()

sendErrorEvent

public void sendErrorEvent(SubjectInfo subjectInfo,
                           com.caplin.datasource.SubjectError subjectError)