Package tigase.server.cluster.strategy
Class ClusteringMetadata
- java.lang.Object
-
- tigase.server.cluster.strategy.ClusteringMetadata
-
- All Implemented Interfaces:
tigase.sys.OnlineJidsReporter
public class ClusteringMetadata extends java.lang.Object implements tigase.sys.OnlineJidsReporter
- Author:
- kobit
-
-
Field Summary
Fields Modifier and Type Field Description protected java.util.Map<tigase.xmpp.jid.BareJID,java.util.Map<tigase.xmpp.jid.JID,ConnectionRecordExt>>
userConnections
-
Constructor Summary
Constructors Constructor Description ClusteringMetadata()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description long
connectionsSize()
boolean
containsJid(tigase.xmpp.jid.BareJID jid)
boolean
containsJidLocally(tigase.xmpp.jid.BareJID jid)
boolean
containsJidLocally(tigase.xmpp.jid.JID jid)
tigase.xmpp.jid.JID[]
getConnectionIdsForJid(tigase.xmpp.jid.BareJID jid)
ConnectionRecordExt
getConnectionRecord(tigase.xmpp.jid.JID jid)
java.util.Set<ConnectionRecordExt>
getConnectionRecords(tigase.xmpp.jid.BareJID bareJID)
java.lang.Object
getInternalData()
java.util.List<tigase.xmpp.jid.JID>
getNodesForJid(tigase.xmpp.jid.JID jid)
boolean
hasCompleteJidsInfo()
long
mapSize()
boolean
needsSync()
void
removeAllForNode(tigase.xmpp.jid.JID node)
void
userDisconnected(java.util.Queue<tigase.server.Packet> results, ConnectionRecordExt rec)
void
usersConnected(java.util.Queue<tigase.server.Packet> results, ConnectionRecordExt... recs)
-
-
-
Field Detail
-
userConnections
protected final java.util.Map<tigase.xmpp.jid.BareJID,java.util.Map<tigase.xmpp.jid.JID,ConnectionRecordExt>> userConnections
-
-
Method Detail
-
connectionsSize
public long connectionsSize()
-
containsJid
public boolean containsJid(tigase.xmpp.jid.BareJID jid)
- Specified by:
containsJid
in interfacetigase.sys.OnlineJidsReporter
-
containsJidLocally
public boolean containsJidLocally(tigase.xmpp.jid.BareJID jid)
- Specified by:
containsJidLocally
in interfacetigase.sys.OnlineJidsReporter
-
containsJidLocally
public boolean containsJidLocally(tigase.xmpp.jid.JID jid)
- Specified by:
containsJidLocally
in interfacetigase.sys.OnlineJidsReporter
-
mapSize
public long mapSize()
-
needsSync
public boolean needsSync()
-
removeAllForNode
public void removeAllForNode(tigase.xmpp.jid.JID node)
-
userDisconnected
public void userDisconnected(java.util.Queue<tigase.server.Packet> results, ConnectionRecordExt rec)
-
usersConnected
public void usersConnected(java.util.Queue<tigase.server.Packet> results, ConnectionRecordExt... recs)
-
getConnectionIdsForJid
public tigase.xmpp.jid.JID[] getConnectionIdsForJid(tigase.xmpp.jid.BareJID jid)
- Specified by:
getConnectionIdsForJid
in interfacetigase.sys.OnlineJidsReporter
-
getConnectionRecord
public ConnectionRecordExt getConnectionRecord(tigase.xmpp.jid.JID jid)
-
getConnectionRecords
public java.util.Set<ConnectionRecordExt> getConnectionRecords(tigase.xmpp.jid.BareJID bareJID)
-
getInternalData
public java.lang.Object getInternalData()
-
getNodesForJid
public java.util.List<tigase.xmpp.jid.JID> getNodesForJid(tigase.xmpp.jid.JID jid)
-
hasCompleteJidsInfo
public boolean hasCompleteJidsInfo()
- Specified by:
hasCompleteJidsInfo
in interfacetigase.sys.OnlineJidsReporter
-
-