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

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	NodeSubscriptions()

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)
UsersSubscription[]	getSubscriptions()
UsersSubscription[]	getSubscriptionsForPublish()
Map<tigase.xmpp.jid.BareJID,UsersSubscription>	getSubscriptionsMap()
void	init(Queue<UsersSubscription> data)
boolean	isChanged()
void	parse(String data)
void	replaceBy(ISubscriptions nodeSubscriptions)
void	resetChangedFlag()
String	serialize(Map<tigase.xmpp.jid.BareJID,UsersSubscription> fragment)
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 String DELIMITER

See Also:

Constant Field Values

log

protected final Logger log

subs

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

Constructor Detail

NodeSubscriptions

protected NodeSubscriptions()

Method Detail

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 UsersSubscription[] getSubscriptions()

Specified by:

getSubscriptions in interface ISubscriptions

getSubscriptionsForPublish

public UsersSubscription[] getSubscriptionsForPublish()

Specified by:

getSubscriptionsForPublish in interface ISubscriptions

getSubscriptionsMap

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

init

public void init(Queue<UsersSubscription> data)

isChanged

public boolean isChanged()

Specified by:

isChanged in interface ISubscriptions

parse

public void parse(String data)

replaceBy

public void replaceBy(ISubscriptions nodeSubscriptions)

resetChangedFlag

public void resetChangedFlag()

serialize

public String serialize(Map<tigase.xmpp.jid.BareJID,UsersSubscription> fragment)

Specified by:

serialize in interface ISubscriptions

toString

public String toString()

Overrides:

toString in class Object

get

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