public class CachedSubscription<T extends SubjectInfo> extends Object
Constructor and Description |
---|
CachedSubscription(T subjectInfo) |
Modifier and Type | Method and Description |
---|---|
Optional<com.caplin.datasource.messaging.Message> |
getLastMessage() |
String |
getLastStaleMessage() |
T |
getSubjectInfo() |
boolean |
isStale() |
void |
setLastMessage(com.caplin.datasource.messaging.Message lastMessage) |
void |
setStale(boolean stale) |
void |
setStale(boolean stale,
String staleMessage) |
public CachedSubscription(T subjectInfo)
public Optional<com.caplin.datasource.messaging.Message> getLastMessage()
public void setLastMessage(com.caplin.datasource.messaging.Message lastMessage)
public boolean isStale()
public String getLastStaleMessage()
public void setStale(boolean stale)
public void setStale(boolean stale, String staleMessage)
public T getSubjectInfo()
Copyright © 2018 Caplin Systems.