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 java.lang.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 java.lang.String	DELIMITER
protected java.util.logging.Logger	log
protected java.util.concurrent.ConcurrentMap<tigase.xmpp.jid.BareJID,UsersSubscription>	subs

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
java.lang.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)
java.lang.String	getSubscriptionId(tigase.xmpp.jid.BareJID bareJid)
java.util.stream.Stream<UsersSubscription>	getSubscriptions()
java.util.stream.Stream<UsersSubscription>	getSubscriptionsForPublish()
void	init(java.util.Queue<UsersSubscription> data)
int	size()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

DELIMITER

protected static final java.lang.String DELIMITER

See Also:

Constant Field Values

log

protected final java.util.logging.Logger log

subs

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

Constructor Detail

NodeSubscriptions

protected NodeSubscriptions()

NodeSubscriptions

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

Method Detail

create

public static NodeSubscriptions create()

addSubscriberJid

public java.lang.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 java.lang.String getSubscriptionId(tigase.xmpp.jid.BareJID bareJid)

Specified by:

getSubscriptionId in interface ISubscriptions

getSubscriptions

public java.util.stream.Stream<UsersSubscription> getSubscriptions()

Specified by:

getSubscriptions in interface ISubscriptions

getSubscriptionsForPublish

public java.util.stream.Stream<UsersSubscription> getSubscriptionsForPublish()

Specified by:

getSubscriptionsForPublish in interface ISubscriptions

init

public void init(java.util.Queue<UsersSubscription> data)

size

public int size()

Specified by:

size in interface ISubscriptions

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

get

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