Package tigase.pubsub.repository

Class PresenceCollectorRepository

java.lang.Object

tigase.pubsub.repository.PresenceCollectorRepository

@ClusterModeRequired(active=false)
@Bean(name="presenceRepository",
      parent=PubSubComponent.class,
      active=true)
public class PresenceCollectorRepository
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	PresenceCollectorRepository.ServiceEntry
class	PresenceCollectorRepository.UserEntry
class	PresenceCollectorRepository.UserResourceEntry

Field Summary

Fields

Modifier and Type	Field	Description
protected final ConcurrentMap<tigase.xmpp.jid.BareJID,PresenceCollectorRepository.ServiceEntry>	entriesByService

Constructor Summary

Constructors

Constructor	Description
PresenceCollectorRepository()

Method Summary

Modifier and Type	Method	Description
String	add(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.JID jid, String caps)
Stream<PresenceCollectorRepository.UserResourceEntry>	expiredUserResourceEntriesStream(long expirationTimestamp)
Stream<tigase.xmpp.jid.JID>	getAllAvailableJids(tigase.xmpp.jid.BareJID serviceJid, Predicate<String> nodesPredicate)
List<tigase.xmpp.jid.JID>	getAllAvailableResources(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.BareJID bareJid)
Collection<PresenceCollectorRepository.ServiceEntry>	getServiceEntries()
boolean	isAvailable(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.BareJID bareJid)
boolean	isAvailable(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.JID jid)
boolean	remove(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.JID jid)
Stream<PresenceCollectorRepository.UserResourceEntry>	userResourceEntryStream()

Methods inherited from class java.lang.Object

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

Field Details

entriesByService

protected final ConcurrentMap<tigase.xmpp.jid.BareJID,PresenceCollectorRepository.ServiceEntry> entriesByService

Constructor Details

PresenceCollectorRepository

public PresenceCollectorRepository()

Method Details

add

public String add(tigase.xmpp.jid.BareJID serviceJid,
 tigase.xmpp.jid.JID jid,
 String caps)

getAllAvailableJids

public Stream<tigase.xmpp.jid.JID> getAllAvailableJids(tigase.xmpp.jid.BareJID serviceJid,
 Predicate<String> nodesPredicate)

getAllAvailableResources

public List<tigase.xmpp.jid.JID> getAllAvailableResources(tigase.xmpp.jid.BareJID serviceJid,
 tigase.xmpp.jid.BareJID bareJid)

isAvailable

public boolean isAvailable(tigase.xmpp.jid.BareJID serviceJid,
 tigase.xmpp.jid.BareJID bareJid)

isAvailable

public boolean isAvailable(tigase.xmpp.jid.BareJID serviceJid,
 tigase.xmpp.jid.JID jid)

remove

public boolean remove(tigase.xmpp.jid.BareJID serviceJid,
 tigase.xmpp.jid.JID jid)

getServiceEntries

public Collection<PresenceCollectorRepository.ServiceEntry> getServiceEntries()

userResourceEntryStream

public Stream<PresenceCollectorRepository.UserResourceEntry> userResourceEntryStream()

expiredUserResourceEntriesStream

public Stream<PresenceCollectorRepository.UserResourceEntry> expiredUserResourceEntriesStream(long expirationTimestamp)