Package tigase.cluster
Class ClusterConnectionSelector
- java.lang.Object
-
- tigase.cluster.ClusterConnectionSelector
-
- All Implemented Interfaces:
ClusterConnectionSelectorIfc
@Bean(name="clusterConnectionSelector", parent=ClusterConnectionManager.class, active=true) public class ClusterConnectionSelector extends java.lang.Object implements ClusterConnectionSelectorIfc
Advanced implementation of ClusterConnectionSelectorIfc which separates packets with priority CLUSTER or higher from other packets in cluster connections by using separate connections for them- Author:
- andrzej
-
-
Field Summary
Fields Modifier and Type Field Description protected static java.lang.String
CLUSTER_SYS_CONNECTIONS_PER_NODE_PROP_KEY
-
Constructor Summary
Constructors Constructor Description ClusterConnectionSelector()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description XMPPIOService<java.lang.Object>
selectConnection(Packet p, ClusterConnection conn)
Method returns XMPPIOService instances which should be used to send packet between cluster nodesvoid
setClusterConnectionHandler(ClusterConnectionHandler handler)
void
setProperties(java.util.Map<java.lang.String,java.lang.Object> props)
-
-
-
Field Detail
-
CLUSTER_SYS_CONNECTIONS_PER_NODE_PROP_KEY
protected static final java.lang.String CLUSTER_SYS_CONNECTIONS_PER_NODE_PROP_KEY
- See Also:
- Constant Field Values
-
-
Method Detail
-
selectConnection
public XMPPIOService<java.lang.Object> selectConnection(Packet p, ClusterConnection conn)
Description copied from interface:ClusterConnectionSelectorIfc
Method returns XMPPIOService instances which should be used to send packet between cluster nodes- Specified by:
selectConnection
in interfaceClusterConnectionSelectorIfc
-
setClusterConnectionHandler
public void setClusterConnectionHandler(ClusterConnectionHandler handler)
- Specified by:
setClusterConnectionHandler
in interfaceClusterConnectionSelectorIfc
-
setProperties
public void setProperties(java.util.Map<java.lang.String,java.lang.Object> props)
- Specified by:
setProperties
in interfaceClusterConnectionSelectorIfc
-
-