|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objecttigase.server.BasicComponent
tigase.server.AbstractMessageReceiver
tigase.server.xmppsession.SessionManager
tigase.cluster.SessionManagerClustered
public class SessionManagerClustered
Class SessionManagerClusteredOld Created: Tue Nov 22 07:07:11 2005
Field Summary | |
---|---|
static String |
MY_DOMAIN_NAME_PROP_KEY
Field description |
static String |
STRATEGY_CLASS_PROP_KEY
Field description |
static String |
STRATEGY_CLASS_PROP_VAL
Field description |
static String |
STRATEGY_CLASS_PROPERTY
Field description |
static int |
SYNC_MAX_BATCH_SIZE
Field description |
Fields inherited from class tigase.server.xmppsession.SessionManager |
---|
ADMIN_COMMAND_NODE, connectionsByFrom |
Fields inherited from class tigase.server.AbstractMessageReceiver |
---|
HOUR, INCOMING_FILTERS_PROP_KEY, INCOMING_FILTERS_PROP_VAL, MAX_QUEUE_SIZE_PROP_KEY, MAX_QUEUE_SIZE_PROP_VAL, maxQueueSize, MINUTE, OUTGOING_FILTERS_PROP_KEY, OUTGOING_FILTERS_PROP_VAL, SECOND |
Fields inherited from class tigase.server.BasicComponent |
---|
admins, SCRIPTS_DIR_PROP_DEF, SCRIPTS_DIR_PROP_KEY, vHostManager |
Fields inherited from interface tigase.server.xmppsession.SessionManagerHandler |
---|
COMMIT_HANDLER_KEY |
Fields inherited from interface tigase.disco.XMPPService |
---|
CMD_FEATURES, DEF_FEATURES, INFO_XMLNS, ITEMS_XMLNS |
Constructor Summary | |
---|---|
SessionManagerClustered()
|
Method Summary | |
---|---|
protected void |
closeSession(XMPPResourceConnection conn,
boolean closeOnly)
|
boolean |
containsJid(tigase.xmpp.JID jid)
Method description |
tigase.xmpp.JID[] |
getConnectionIdsForJid(tigase.xmpp.JID jid)
Method description |
Map<String,Object> |
getDefaults(Map<String,Object> params)
Method description |
protected tigase.xmpp.JID |
getFirstClusterNode(tigase.xmpp.JID userJid)
|
void |
getStatistics(StatisticsList list)
Method description |
void |
handlePresenceSet(XMPPResourceConnection conn)
Method description |
void |
handleResourceBind(XMPPResourceConnection conn)
Method description |
boolean |
hasCompleteJidsInfo()
Method description |
void |
nodeConnected(String node)
Method description |
void |
nodeDisconnected(String node)
Method description |
protected void |
processClusterPacket(Packet packet)
|
int |
processingThreads()
Method description |
protected void |
processPacket(ClusterElement packet)
|
void |
processPacket(Packet packet)
Method description |
protected boolean |
sendToNextNode(ClusterElement clel,
tigase.xmpp.JID userId)
|
protected boolean |
sendToNextNode(Packet packet)
|
void |
setClusterController(ClusterController cl_controller)
Method description |
void |
setProperties(Map<String,Object> props)
Method description |
protected void |
updateUserResources(XMPPResourceConnection res_con,
Queue<Packet> results)
|
Methods inherited from class tigase.server.AbstractMessageReceiver |
---|
addOutPacketNB, addOutPackets, addOutPacketWithTimeout, addPacket, addPacketNB, addPackets, addRegexRouting, addTimerTask, addTimerTask, clearRegexRoutings, everyHour, everyMinute, everySecond, getRegexRoutings, hashCodeForPacket, isInRegexRoutings, newPacketId, processPacket, release, removeRegexRouting, setMaxQueueSize, setParent, start, stop |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface tigase.server.ServerComponent |
---|
getComponentId, getName, initializationCompleted, processPacket, release, setName |
Methods inherited from interface tigase.server.xmppsession.SessionManagerHandler |
---|
getComponentId |
Methods inherited from interface tigase.server.MessageReceiver |
---|
getDefHostName |
Field Detail |
---|
public static final String MY_DOMAIN_NAME_PROP_KEY
public static final String STRATEGY_CLASS_PROPERTY
public static final String STRATEGY_CLASS_PROP_KEY
public static final String STRATEGY_CLASS_PROP_VAL
public static final int SYNC_MAX_BATCH_SIZE
Constructor Detail |
---|
public SessionManagerClustered()
Method Detail |
---|
public boolean containsJid(tigase.xmpp.JID jid)
containsJid
in interface OnlineJidsReporter
containsJid
in class SessionManager
jid
-
public tigase.xmpp.JID[] getConnectionIdsForJid(tigase.xmpp.JID jid)
getConnectionIdsForJid
in interface OnlineJidsReporter
getConnectionIdsForJid
in class SessionManager
jid
-
public Map<String,Object> getDefaults(Map<String,Object> params)
getDefaults
in interface Configurable
getDefaults
in class SessionManager
params
-
public void getStatistics(StatisticsList list)
SessionManager
getStatistics
in interface StatisticsContainer
getStatistics
in class SessionManager
list
- public void handlePresenceSet(XMPPResourceConnection conn)
handlePresenceSet
in interface SessionManagerHandler
handlePresenceSet
in class SessionManager
conn
- public void handleResourceBind(XMPPResourceConnection conn)
handleResourceBind
in interface SessionManagerHandler
handleResourceBind
in class SessionManager
conn
- public boolean hasCompleteJidsInfo()
hasCompleteJidsInfo
in interface OnlineJidsReporter
hasCompleteJidsInfo
in class SessionManager
public void nodeConnected(String node)
nodeConnected
in interface ClusteredComponent
node
- public void nodeDisconnected(String node)
nodeDisconnected
in interface ClusteredComponent
node
- public void processPacket(Packet packet)
processPacket
in class SessionManager
packet
- public int processingThreads()
processingThreads
in class SessionManager
public void setClusterController(ClusterController cl_controller)
setClusterController
in interface ClusteredComponent
cl_controller
- public void setProperties(Map<String,Object> props)
setProperties
in interface Configurable
setProperties
in class SessionManager
props
- protected void closeSession(XMPPResourceConnection conn, boolean closeOnly)
closeSession
in class SessionManager
protected tigase.xmpp.JID getFirstClusterNode(tigase.xmpp.JID userJid)
@TODO(note="Possible performance bottleneck if there are many users with multiple connections to different nodes.") protected void processClusterPacket(Packet packet) throws tigase.util.TigaseStringprepException
tigase.util.TigaseStringprepException
protected void processPacket(ClusterElement packet)
protected boolean sendToNextNode(ClusterElement clel, tigase.xmpp.JID userId) throws tigase.util.TigaseStringprepException
tigase.util.TigaseStringprepException
protected boolean sendToNextNode(Packet packet)
protected void updateUserResources(XMPPResourceConnection res_con, Queue<Packet> results)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |