Package tigase.pubsub.repository

Class NodeSubscriptions

java.lang.Object

tigase.pubsub.repository.NodeSubscriptions

All Implemented Interfaces:

ISubscriptions

Direct Known Subclasses:

NodeSubscriptions

public abstract class NodeSubscriptions
extends Object
implements ISubscriptions

Implementation of PubSub node subscription handling.

Version:

5.0.0, 2010.03.27 at 05:27:46 GMT

Author:

Artur Hefczyc

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	DELIMITER
protected static final Logger	log
protected final ConcurrentMap<tigase.xmpp.jid.BareJID,UsersSubscription>	subs

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	NodeSubscriptions()
protected	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(tigase.xmpp.jid.BareJID bareJid, Subscription subscription)
static NodeSubscriptions	create()
protected UsersSubscription	get(tigase.xmpp.jid.BareJID bareJid)
Subscription	getSubscription(tigase.xmpp.jid.BareJID bareJid)
String	getSubscriptionId(tigase.xmpp.jid.BareJID bareJid)
Stream<UsersSubscription>	getSubscriptions()
Stream<UsersSubscription>	getSubscriptionsForPublish()
void	init(Queue<UsersSubscription> data)
int	size()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

DELIMITER

protected static final String DELIMITER

See Also:

• Constant Field Values

log

protected static final Logger log

subs

protected final ConcurrentMap<tigase.xmpp.jid.BareJID,UsersSubscription> subs

Constructor Details

NodeSubscriptions

protected NodeSubscriptions()

NodeSubscriptions

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

Method Details

create

public static NodeSubscriptions create()

addSubscriberJid

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

Specified by:

addSubscriberJid in interface ISubscriptions

changeSubscription

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

Specified by:

changeSubscription in interface ISubscriptions

getSubscription

public Subscription getSubscription(tigase.xmpp.jid.BareJID bareJid)

Specified by:

getSubscription in interface ISubscriptions

getSubscriptionId

public String getSubscriptionId(tigase.xmpp.jid.BareJID bareJid)

Specified by:

getSubscriptionId in interface ISubscriptions

getSubscriptions

public Stream<UsersSubscription> getSubscriptions()

Specified by:

getSubscriptions in interface ISubscriptions

getSubscriptionsForPublish

public Stream<UsersSubscription> getSubscriptionsForPublish()

Specified by:

getSubscriptionsForPublish in interface ISubscriptions

init

public void init(Queue<UsersSubscription> data)

size

public int size()

Specified by:

size in interface ISubscriptions

toString

public String toString()

Overrides:

toString in class Object

get

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