Modifier and Type | Class and Description |
---|---|
static class |
FndTopic.FndListener<SP> |
Topic.Listener<DP,DR,SP,SR>, Topic.MetaGetBuilder, Topic.NoteType, Topic.TopicType
LocalData.Payload
Constructor and Description |
---|
FndTopic(Tinode tinode,
Topic.Listener<java.lang.String,java.lang.String,SP,java.lang.String[]> l) |
Modifier and Type | Method and Description |
---|---|
protected void |
addSubToCache(Subscription<SP,java.lang.String[]> sub)
Add subscription to cache.
|
Subscription<SP,java.lang.String[]> |
getSubscription(java.lang.String key) |
java.util.Collection<Subscription<SP,java.lang.String[]>> |
getSubscriptions() |
protected PromisedReply<ServerMessage> |
publish(Drafty content,
java.util.Map<java.lang.String,java.lang.Object> head,
long id) |
protected void |
routeMetaSub(MsgServerMeta<java.lang.String,java.lang.String,SP,java.lang.String[]> meta) |
PromisedReply<ServerMessage> |
setMeta(MsgSetMeta<java.lang.String,java.lang.String> meta)
Update topic metadata
|
protected void |
setStorage(Storage store)
Assign pointer to cache.
|
void |
setTypes(com.fasterxml.jackson.databind.JavaType typeOfSubPu) |
allMessagesReceived, allSubsReceived, compareTo, delete, delMessages, delMessages, delMessages, eject, expunge, getAccessMode, getAnonAcs, getAnonAcsStr, getAuthAcs, getAuthAcsStr, getCachedMessagesRange, getClear, getCreated, getDefacs, getLastSeen, getLastSeenUA, getLocal, getMaxDel, getMeta, getMetaGetBuilder, getMissingMessageRange, getName, getOnline, getPriv, getPub, getRead, getRecv, getSeq, getSubsUpdated, getTags, getTopicType, getTopicTypeByName, getTouched, getTrusted, getUnreadCount, getUpdated, invite, isApprover, isArchived, isAttached, isBlocked, isDeleted, isDeleter, isFndType, isGrpType, isGrpType, isJoiner, isManager, isMeType, isMuted, isNew, isNew, isOwner, isP2PType, isP2PType, isPersisted, isReader, isSharer, isTrusted, isTrustedDanger, isTrustedStaff, isTrustedVerified, isUserType, isValid, isWriter, leave, leave, loadSubs, msgReadCount, msgRecvCount, noteKeyPress, noteRead, noteRead, noteRead, noteReadRecv, noteRecv, noteRecv, persist, processSub, publish, publish, publish, removeSubFromCache, routeData, routeInfo, routeMeta, routeMetaDel, routeMetaDesc, routeMetaTags, routePres, setAccessMode, setClear, setCreated, setDefacs, setDefacs, setDeleted, setDescription, setDescription, setLastSeen, setLastSeen, setListener, setLocal, setMaxDel, setName, setOnline, setPriv, setPub, setRead, setReadRecvByRemote, setRecv, setSeq, setSeqAndFetch, setSubscription, setTags, setTouched, setTrusted, setTypes, setTypes, setTypes, setUpdated, subscribe, subscribe, syncAll, syncOne, topicLeft, update, update, update, update, update, update, updateAccessMode, updateAdmin, updateDefAcs, updateMode, updateMode, updateMuted, updateSharer
public FndTopic(Tinode tinode, Topic.Listener<java.lang.String,java.lang.String,SP,java.lang.String[]> l)
public void setTypes(com.fasterxml.jackson.databind.JavaType typeOfSubPu)
public PromisedReply<ServerMessage> setMeta(MsgSetMeta<java.lang.String,java.lang.String> meta)
Topic
protected PromisedReply<ServerMessage> publish(Drafty content, java.util.Map<java.lang.String,java.lang.Object> head, long id)
protected void addSubToCache(Subscription<SP,java.lang.String[]> sub)
addSubToCache
in class Topic<java.lang.String,java.lang.String,SP,java.lang.String[]>
sub
- subscription to add to cacheprotected void routeMetaSub(MsgServerMeta<java.lang.String,java.lang.String,SP,java.lang.String[]> meta)
routeMetaSub
in class Topic<java.lang.String,java.lang.String,SP,java.lang.String[]>
public Subscription<SP,java.lang.String[]> getSubscription(java.lang.String key)
getSubscription
in class Topic<java.lang.String,java.lang.String,SP,java.lang.String[]>
public java.util.Collection<Subscription<SP,java.lang.String[]>> getSubscriptions()
getSubscriptions
in class Topic<java.lang.String,java.lang.String,SP,java.lang.String[]>
protected void setStorage(Storage store)
Topic
Tinode.startTrackingTopic(Topic)
setStorage
in class Topic<java.lang.String,java.lang.String,SP,java.lang.String[]>
store
- storage object