Package com.caplin.motif.datasource

Class JsonMessagePublisher<T extends SubjectInfo,E>

java.lang.Object

com.caplin.motif.datasource.JsonMessagePublisher<T,E>

public class JsonMessagePublisher<T extends SubjectInfo,E>
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
JsonMessagePublisher(com.caplin.datasource.publisher.CachingPublisher publisher)

Method Summary

Modifier and Type	Method	Description
void	publishMessage(T subjectInfo, E message)
void	sendErrorEvent(SubjectInfo subjectInfo, com.caplin.datasource.SubjectError subjectError)
void	sendNotFound(SubjectInfo info)
void	sendNotStale(SubjectInfo info)
void	sendStale(SubjectInfo info, java.lang.String message)
void	sendSubjectStatusEvent(SubjectInfo info, com.caplin.datasource.SubjectStatus subjectStatus, java.lang.String message)
void	sendSubscribeFail(SubjectInfo info)

Methods inherited from class java.lang.Object

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

Constructor Detail

JsonMessagePublisher

public JsonMessagePublisher(com.caplin.datasource.publisher.CachingPublisher publisher)

Method Detail

publishMessage

public void publishMessage(T subjectInfo,
                           E message)

sendSubscribeFail

public void sendSubscribeFail(SubjectInfo info)

sendStale

public void sendStale(SubjectInfo info,
                      java.lang.String message)

sendNotStale

public void sendNotStale(SubjectInfo info)

sendSubjectStatusEvent

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

sendNotFound

public void sendNotFound(SubjectInfo info)

sendErrorEvent

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