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 final ThreadLocal<Map<tigase.xmpp.jid.BareJID,UsersSubscription>>	changedSubs
protected static final Logger	log

Fields inherited from class tigase.pubsub.repository.NodeSubscriptions

DELIMITER, subs

Constructor Summary

Constructors

Constructor	Description
NodeSubscriptions()
NodeSubscriptions(Map<tigase.xmpp.jid.BareJID,UsersSubscription> subscriptions)

Method Summary

Modifier and Type	Method	Description
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)
Map<tigase.xmpp.jid.BareJID,UsersSubscription>	getChanged()
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 Details

log

protected static final Logger log

changedSubs

protected final ThreadLocal<Map<tigase.xmpp.jid.BareJID,UsersSubscription>> changedSubs

Constructor Details

NodeSubscriptions

public NodeSubscriptions()

NodeSubscriptions

public NodeSubscriptions(Map<tigase.xmpp.jid.BareJID,UsersSubscription> subscriptions)

Method Details

addSubscriberJid

public String addSubscriberJid(tigase.xmpp.jid.BareJID bareJid,
 Subscription subscription)

Specified by:

addSubscriberJid in interface ISubscriptions

Overrides:

addSubscriberJid in class NodeSubscriptions

changeSubscription

public void changeSubscription(tigase.xmpp.jid.BareJID bareJid,
 Subscription subscription)

Specified by:

changeSubscription in interface ISubscriptions

Overrides:

changeSubscription in class NodeSubscriptions

changeSubscription

public void changeSubscription(UsersSubscription subscription)

Specified by:

changeSubscription in interface ISubscriptionsCached

getChanged

public Map<tigase.xmpp.jid.BareJID,UsersSubscription> getChanged()

Specified by:

getChanged in interface ISubscriptionsCached

getSubscriptions

public Stream<UsersSubscription> getSubscriptions()

Specified by:

getSubscriptions in interface ISubscriptions

Overrides:

getSubscriptions in class NodeSubscriptions

isChanged

public boolean isChanged()

Specified by:

isChanged in interface ISubscriptionsCached

merge

public void merge()

Specified by:

merge in interface ISubscriptionsCached

resetChangedFlag

public void resetChangedFlag()

Specified by:

resetChangedFlag in interface ISubscriptionsCached

get

protected UsersSubscription get(tigase.xmpp.jid.BareJID bareJid)

Overrides:

get in class NodeSubscriptions