Package tigase.pubsub.repository.cached
Class NodeSubscriptions
- java.lang.Object
-
- tigase.pubsub.repository.NodeSubscriptions
-
- tigase.pubsub.repository.cached.NodeSubscriptions
-
- All Implemented Interfaces:
ISubscriptionsCached
,ISubscriptions
public class NodeSubscriptions extends NodeSubscriptions implements ISubscriptionsCached
-
-
Field Summary
Fields Modifier and Type Field Description protected java.lang.ThreadLocal<java.util.Map<tigase.xmpp.jid.BareJID,UsersSubscription>>
changedSubs
-
Fields inherited from class tigase.pubsub.repository.NodeSubscriptions
DELIMITER, log, subs
-
-
Constructor Summary
Constructors Constructor Description NodeSubscriptions()
NodeSubscriptions(java.util.Map<tigase.xmpp.jid.BareJID,UsersSubscription> subscriptions)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.String
addSubscriberJid(tigase.xmpp.jid.BareJID bareJid, Subscription subscription)
void
changeSubscription(UsersSubscription subscription)
void
changeSubscription(tigase.xmpp.jid.BareJID bareJid, Subscription subscription)
protected UsersSubscription
get(tigase.xmpp.jid.BareJID bareJid)
java.util.Map<tigase.xmpp.jid.BareJID,UsersSubscription>
getChanged()
java.util.stream.Stream<UsersSubscription>
getSubscriptions()
boolean
isChanged()
void
merge()
void
resetChangedFlag()
-
Methods inherited from class tigase.pubsub.repository.NodeSubscriptions
create, getSubscription, getSubscriptionId, getSubscriptionsForPublish, init, size, toString
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface tigase.pubsub.repository.ISubscriptions
getSubscription, getSubscriptionId, getSubscriptionsForPublish, size
-
-
-
-
Field Detail
-
changedSubs
protected final java.lang.ThreadLocal<java.util.Map<tigase.xmpp.jid.BareJID,UsersSubscription>> changedSubs
-
-
Constructor Detail
-
NodeSubscriptions
public NodeSubscriptions()
-
NodeSubscriptions
public NodeSubscriptions(java.util.Map<tigase.xmpp.jid.BareJID,UsersSubscription> subscriptions)
-
-
Method Detail
-
addSubscriberJid
public java.lang.String addSubscriberJid(tigase.xmpp.jid.BareJID bareJid, Subscription subscription)
- Specified by:
addSubscriberJid
in interfaceISubscriptions
- Overrides:
addSubscriberJid
in classNodeSubscriptions
-
changeSubscription
public void changeSubscription(tigase.xmpp.jid.BareJID bareJid, Subscription subscription)
- Specified by:
changeSubscription
in interfaceISubscriptions
- Overrides:
changeSubscription
in classNodeSubscriptions
-
changeSubscription
public void changeSubscription(UsersSubscription subscription)
- Specified by:
changeSubscription
in interfaceISubscriptionsCached
-
getChanged
public java.util.Map<tigase.xmpp.jid.BareJID,UsersSubscription> getChanged()
- Specified by:
getChanged
in interfaceISubscriptionsCached
-
getSubscriptions
public java.util.stream.Stream<UsersSubscription> getSubscriptions()
- Specified by:
getSubscriptions
in interfaceISubscriptions
- Overrides:
getSubscriptions
in classNodeSubscriptions
-
isChanged
public boolean isChanged()
- Specified by:
isChanged
in interfaceISubscriptionsCached
-
merge
public void merge()
- Specified by:
merge
in interfaceISubscriptionsCached
-
resetChangedFlag
public void resetChangedFlag()
- Specified by:
resetChangedFlag
in interfaceISubscriptionsCached
-
get
protected UsersSubscription get(tigase.xmpp.jid.BareJID bareJid)
- Overrides:
get
in classNodeSubscriptions
-
-