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 java.lang.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 java.util.concurrent.ConcurrentMap<tigase.xmpp.jid.BareJID,PresenceCollectorRepository.ServiceEntry>	entriesByService

Constructor Summary

Constructors

Constructor	Description
PresenceCollectorRepository()

Method Summary

Modifier and Type	Method	Description
java.lang.String	add(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.JID jid, java.lang.String caps)
java.util.stream.Stream<PresenceCollectorRepository.UserResourceEntry>	expiredUserResourceEntriesStream(long expirationTimestamp)
java.util.stream.Stream<tigase.xmpp.jid.JID>	getAllAvailableJids(tigase.xmpp.jid.BareJID serviceJid, java.util.function.Predicate<java.lang.String> nodesPredicate)
java.util.List<tigase.xmpp.jid.JID>	getAllAvailableResources(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.BareJID bareJid)
java.util.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)
java.util.stream.Stream<PresenceCollectorRepository.UserResourceEntry>	userResourceEntryStream()

Methods inherited from class java.lang.Object

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

Field Detail

entriesByService

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

Constructor Detail

PresenceCollectorRepository

public PresenceCollectorRepository()

Method Detail

add

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

getAllAvailableJids

public java.util.stream.Stream<tigase.xmpp.jid.JID> getAllAvailableJids(tigase.xmpp.jid.BareJID serviceJid,
                                                                        java.util.function.Predicate<java.lang.String> nodesPredicate)

getAllAvailableResources

public java.util.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 java.util.Collection<PresenceCollectorRepository.ServiceEntry> getServiceEntries()

userResourceEntryStream

public java.util.stream.Stream<PresenceCollectorRepository.UserResourceEntry> userResourceEntryStream()

expiredUserResourceEntriesStream

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