E
- public class DefaultClusteringStrategy<E extends ConnectionRecordIfc> extends DefaultClusteringStrategyAbstract<E>
Modifier and Type | Field and Description |
---|---|
static String |
CONNECTION_ID
Field description
|
static String |
RESOURCE
Field description
|
static String |
SM_ID
Field description
|
static String |
USER_ID
Field description
|
static String |
XMPP_SESSION_ID
Field description
|
cl_nodes_list, cluster, sm
Constructor and Description |
---|
DefaultClusteringStrategy()
Constructs ...
|
Modifier and Type | Method and Description |
---|---|
protected ConnectionRecordIfc |
getConnectionRecord(tigase.xmpp.JID node,
Map<String,String> data)
Method takes the data received from other cluster node and creates a
ConnectionRecord with all essential connection information.
|
List<tigase.xmpp.JID> |
getNodesForPacketForward(tigase.xmpp.JID fromNode,
Set<tigase.xmpp.JID> visitedNodes,
Packet packet)
Method description
|
void |
handleLocalPacket(Packet packet,
XMPPResourceConnection conn)
Method description
|
void |
handleLocalResourceBind(XMPPResourceConnection conn)
Method description
|
void |
handleLocalUserLogout(tigase.xmpp.BareJID userId,
XMPPResourceConnection conn)
Method description
|
protected Map<String,String> |
prepareConnectionParams(XMPPResourceConnection conn)
A utility method used to prepare a Map of data with user session data
before it can be sent over to another cluster node.
|
addCommandListener, containsJid, containsJidLocally, containsJidLocally, getAllNodes, getConnectionIdsForJid, getConnectionRecord, getConnectionRecordInstance, getConnectionRecords, getDefaults, getInfo, getInternalCacheData, getSM, getStatistics, handleLocalPresenceSet, handleLocalUserLogin, hasCompleteJidsInfo, isSuitableForForward, nodeConnected, nodeDisconnected, processPacket, sendToNextNode, setClusterController, setProperties, setSessionManagerHandler, toString
public static final String CONNECTION_ID
public static final String RESOURCE
public static final String SM_ID
public static final String USER_ID
public static final String XMPP_SESSION_ID
public void handleLocalPacket(Packet packet, XMPPResourceConnection conn)
handleLocalPacket
in interface ClusteringStrategyIfc<E extends ConnectionRecordIfc>
handleLocalPacket
in class DefaultClusteringStrategyAbstract<E extends ConnectionRecordIfc>
packet
- conn
- public void handleLocalResourceBind(XMPPResourceConnection conn)
handleLocalResourceBind
in interface ClusteringStrategyIfc<E extends ConnectionRecordIfc>
handleLocalResourceBind
in class DefaultClusteringStrategyAbstract<E extends ConnectionRecordIfc>
conn
- public void handleLocalUserLogout(tigase.xmpp.BareJID userId, XMPPResourceConnection conn)
handleLocalUserLogout
in interface ClusteringStrategyIfc<E extends ConnectionRecordIfc>
handleLocalUserLogout
in class DefaultClusteringStrategyAbstract<E extends ConnectionRecordIfc>
userId
- conn
- public List<tigase.xmpp.JID> getNodesForPacketForward(tigase.xmpp.JID fromNode, Set<tigase.xmpp.JID> visitedNodes, Packet packet)
getNodesForPacketForward
in class DefaultClusteringStrategyAbstract<E extends ConnectionRecordIfc>
fromNode
- is a JID
visitedNodes
- is a Set
packet
- is a Packet
List
protected Map<String,String> prepareConnectionParams(XMPPResourceConnection conn) throws NotAuthorizedException, NoConnectionIdException
conn
- is user's XMPPResourceConnection for which Map structure is
prepare.NoConnectionIdException
NotAuthorizedException
protected ConnectionRecordIfc getConnectionRecord(tigase.xmpp.JID node, Map<String,String> data)
node
- data
- Copyright © 2014 "Tigase, Inc.". All rights reserved.