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 Details

    • SubjectMessagePublisher

      public SubjectMessagePublisher(com.caplin.datasource.publisher.CachingPublisher 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)

    • sendErrorEvent

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