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 Details

    • SubjectMessagePublisher

      public SubjectMessagePublisher(CachedPublisher publisher, boolean useGenerics)
  • Method Details

    • 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)