com.caplin.motif.datasource

Class CachedSubscriptionManager<T extends SubjectInfo>

java.lang.Object

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

public class CachedSubscriptionManager<T extends SubjectInfo>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CachedSubscriptionManager.UpdateCachedMessageResult

Constructor Summary

Constructors

Constructor and Description
CachedSubscriptionManager(CachedDataProvider<T> dataProvider, SubjectParser<T> subjectParser)

Method Summary

Modifier and Type	Method and Description
void	clearAll()
void	clearAndUnsubscribe(String subject)
boolean	getAndSetStaleStatus(String subject, boolean newStaleValue)
CachedSubscription	getOrCreateAndSubscribe(String subject)
CachedSubscriptionManager.UpdateCachedMessageResult	updateCachedMessage(String subject, com.caplin.datasource.messaging.Message newMessage)

Methods inherited from class java.lang.Object

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

Constructor Detail

CachedSubscriptionManager

public CachedSubscriptionManager(CachedDataProvider<T> dataProvider,
                                 SubjectParser<T> subjectParser)

Method Detail

getOrCreateAndSubscribe

public CachedSubscription getOrCreateAndSubscribe(String subject)
                                           throws SubjectParserException

Throws:

SubjectParserException

updateCachedMessage

public CachedSubscriptionManager.UpdateCachedMessageResult updateCachedMessage(String subject,
                                                                               com.caplin.datasource.messaging.Message newMessage)

clearAndUnsubscribe

public void clearAndUnsubscribe(String subject)

clearAll

public void clearAll()

getAndSetStaleStatus

public boolean getAndSetStaleStatus(String subject,
                                    boolean newStaleValue)