Package com.caplin.motif.datasource

Class ObjectPublisher<S,T extends SubjectInfo>

java.lang.Object

com.caplin.motif.datasource.ObjectPublisher<S,T>

Type Parameters:

S - the type of object this publisher publishes

T - the type of SubjectInfo the subject is parsed into

All Implemented Interfaces:

com.caplin.datasource.publisher.CachingDataProvider

public class ObjectPublisher<S,T extends SubjectInfo>
extends Object
implements com.caplin.datasource.publisher.CachingDataProvider

Publishes objects by serialising before sending on the wire.

Constructor Summary

Constructors

Constructor	Description
ObjectPublisher(@NotNull SubjectParser<T> subjectParser, @NotNull CachedObjectProvider<S,T> provider)

Method Summary

Modifier and Type	Method	Description
void	onDiscard(String subject)
void	onRequest(String subject)
void	setPublisher(@NotNull com.caplin.datasource.publisher.CachingPublisher cachingPublisher)

Methods inherited from class java.lang.Object

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

Constructor Details

ObjectPublisher

public ObjectPublisher(@NotNull
 @NotNull SubjectParser<T> subjectParser,
 @NotNull
 @NotNull CachedObjectProvider<S,T> provider)

Method Details

setPublisher

public void setPublisher(@NotNull
 @NotNull com.caplin.datasource.publisher.CachingPublisher cachingPublisher)

Specified by:

setPublisher in interface com.caplin.datasource.publisher.CachingDataProvider

onRequest

public void onRequest(String subject)

Specified by:

onRequest in interface com.caplin.datasource.publisher.CachingDataProvider

onDiscard

public void onDiscard(String subject)

Specified by:

onDiscard in interface com.caplin.datasource.publisher.CachingDataProvider