ConnectionManager (Tigase XMPP Server 7.1.5 API)

java.lang.Object
- tigase.server.BasicComponent
- - tigase.server.AbstractMessageReceiver
  - - tigase.server.ConnectionManager<IO>

Type Parameters:

IO -

All Implemented Interfaces:

ClusteredComponentIfc, Configurable, XMPPService, IOServiceListener<IO>, MessageReceiver, ServerComponent, StatisticsContainer, StatisticsContainerIfc, VHostListener, XMPPIOServiceListener<IO>

Direct Known Subclasses:

ClientConnectionManager, ClusterConnectionManager, ComponentConnectionManager, ComponentProtocol, S2SConnectionManager, ServerConnectionManager
```
public abstract class ConnectionManager<IO extends XMPPIOService<?>>
extends AbstractMessageReceiver
implements XMPPIOServiceListener<IO>
```
Describe class ConnectionManager here. Created: Sun Jan 22 22:52:58 2006

Version:

$Rev$

Author:

Artur Hefczyc

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`static class`	`ConnectionManager.LIMIT_ACTION` Describe class `LIMIT_ACTION` here.
`protected class`	`ConnectionManager.Watchdog` Class looks in all established connections and checks whether any of them is dead by performing either whitspace or XMPP ping.
`static class`	`ConnectionManager.WATCHDOG_PING_TYPE` Holds possible types of ping to be used in watchdog service for detection of broken connections

Field Summary

Fields
Modifier and Type	Field and Description
`protected long`	`connectionDelay`
`protected boolean`	`delayPortListening`
`protected int`	`elements_number_limit` Protection from the system overload and DOS attack.
`static String`	`ELEMENTS_NUMBER_LIMIT_PROP_KEY` Key name of the system property for configuration protection from system overload and DOS attack.
`static int`	`ELEMENTS_NUMBER_LIMIT_PROP_VAL` Default value for the system property for configuration protection from system overload and DOS attack.
`static String`	`HT_TRAFFIC_THROTTLING_PROP_KEY`
`static String`	`HT_TRAFFIC_THROTTLING_PROP_VAL`
`protected static long`	`LAST_MINUTE_BIN_LIMIT_PROP_VAL`
`protected static long`	`LAST_MINUTE_PACKETS_LIMIT_PROP_VAL`
`protected static String`	`MAX_INACTIVITY_TIME`
`protected static String`	`MAX_RECONNECTS_PROP_KEY`
`protected int`	`net_buffer`
`static String`	`NET_BUFFER_HT_PROP_KEY`
`protected static int`	`NET_BUFFER_HT_PROP_VAL`
`protected static int`	`NET_BUFFER_LIMIT_HT_PROP_VAL`
`protected static String`	`NET_BUFFER_LIMIT_PROP_KEY`
`protected static int`	`NET_BUFFER_LIMIT_ST_PROP_VAL`
`protected static String`	`NET_BUFFER_PROP_KEY`
`static String`	`NET_BUFFER_ST_PROP_KEY`
`protected static int`	`NET_BUFFER_ST_PROP_VAL`
`protected static Element`	`pingElement`
`protected static String`	`PORT_CLASS_PROP_KEY`
`protected static String`	`PORT_IFC_PROP_KEY`
`String[]`	`PORT_IFC_PROP_VAL`
`protected static String`	`PORT_KEY`
`protected static boolean`	`PORT_LISTENING_DELAY_DEF`
`protected static String`	`PORT_LISTENING_DELAY_KEY`
`static String`	`PORT_LOCAL_HOST_PROP_KEY`
`protected static String`	`PORT_REMOTE_HOST_PROP_KEY`
`protected static String`	`PORT_REMOTE_HOST_PROP_VAL`
`protected static String`	`PORT_SOCKET_PROP_KEY`
`protected static String`	`PORT_TYPE_PROP_KEY`
`protected static String`	`PORTS_PROP_KEY`
`protected XMPPIOProcessor[]`	`processors`
`protected static String`	`PROP_KEY`
`static String`	`ST_TRAFFIC_THROTTLING_PROP_KEY`
`static String`	`ST_TRAFFIC_THROTTLING_PROP_VAL`
`protected static String`	`TLS_PROP_KEY`
`protected static String`	`TLS_REQUIRED_PROP_KEY`
`protected static boolean`	`TLS_REQUIRED_PROP_VAL`
`protected static String`	`TLS_USE_PROP_KEY`
`protected static boolean`	`TLS_USE_PROP_VAL`
`protected static long`	`TOTAL_BIN_LIMIT_PROP_VAL`
`protected static long`	`TOTAL_PACKETS_LIMIT_PROP_VAL`
`static String`	`TRAFFIC_THROTTLING_PROP_KEY`
`protected static String`	`WATCHDOG_DELAY`
`protected static String`	`WATCHDOG_PING_TYPE_KEY`
`protected static String`	`WATCHDOG_TIMEOUT`
`protected long`	`watchdogDelay`
`protected ConnectionManager.WATCHDOG_PING_TYPE`	`watchdogPingType`
`protected long`	`watchdogTimeout`
`protected static String`	`WHITE_CHAR_ACK_PROP_KEY`
`protected static boolean`	`WHITE_CHAR_ACK_PROP_VAL`
`protected static String`	`XMPP_ACK_PROP_KEY`
`protected static boolean`	`XMPP_ACK_PROP_VAL`

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, maxInQueueSize, maxOutQueueSize, maxQueueSize, MINUTE, OUTGOING_FILTERS_PROP_KEY, OUTGOING_FILTERS_PROP_VAL, PACKET_DELIVERY_RETRY_COUNT_PROP_KEY, SCHEDULER_THREADS_PROP_KEY, SECOND

Fields inherited from class tigase.server.BasicComponent
admins, ALL_PROP_KEY, COMMAND_PROP_NODE, scriptCommands, SCRIPTS_DIR_PROP_DEF, SCRIPTS_DIR_PROP_KEY, trusted, vHostManager

Fields inherited from interface tigase.conf.Configurable
ADMINS_PROP_KEY, AMP_CLASS_NAME, AMP_CLUST_CLASS_NAME, AUTH_DOMAIN_POOL_CLASS, AUTH_REPO_DOMAINS_PROP_KEY, AUTH_REPO_PARAMS_NODE, AUTH_REPO_POOL_CLASS, AUTH_REPO_URL_PROP_KEY, BOSH_CLUST_COMP_CLASS_NAME, BOSH_COMP_CLASS_NAME, C2S_CLUST_COMP_CLASS_NAME, C2S_COMP_CLASS_NAME, CL_COMP_CLASS_NAME, CLUSTER_CONECT, CLUSTER_CONTR_CLASS_NAME, CLUSTER_LISTEN, CLUSTER_MODE, CLUSTER_NODES, CLUSTER_NODES_PROP_KEY, COMP_PROT_CLASS_NAME, COMPONENT_ID_PROP_KEY, DEF_AMP_NAME, DEF_BOSH_NAME, DEF_C2S_NAME, DEF_CL_COMP_NAME, DEF_CLUST_CONTR_NAME, DEF_COMP_PROT_NAME, DEF_EVENTBUS_NAME, DEF_EXT_COMP_NAME, DEF_HOSTNAME_PROP_KEY, DEF_MONITOR_NAME, DEF_S2S_NAME, DEF_SM_NAME, DEF_SRECV_NAME, DEF_SSEND_NAME, DEF_STATS_NAME, DEF_VHOST_MAN_NAME, DEF_WS2S_NAME, DERBY_REPO_CLASS_PROP_VAL, DERBY_REPO_URL_PROP_VAL, DRUPAL_REPO_URL_PROP_VAL, DRUPALWP_REPO_CLASS_PROP_VAL, DUMMY_REPO_CLASS_PROP_VAL, EVENTBUS_CLASS_NAME, EXT_COMP_CLASS_NAME, GEN_ADMINS, GEN_AUTH_DB, GEN_AUTH_DB_URI, GEN_COMP_CLASS, GEN_COMP_NAME, GEN_CONF, GEN_CONFIG, GEN_CONFIG_ALL, GEN_CONFIG_COMP, GEN_CONFIG_CS, GEN_CONFIG_DEF, GEN_CONFIG_SM, GEN_DEBUG, GEN_DEBUG_PACKAGES, GEN_EXT_COMP, GEN_MAX_QUEUE_SIZE, GEN_SCRIPT_DIR, GEN_SM_PLUGINS, GEN_SREC_ADMINS, GEN_SREC_DB, GEN_SREC_DB_URI, GEN_TEST, GEN_TRUSTED, GEN_USER_DB, GEN_USER_DB_URI, GEN_USER_DB_URI_PROP_KEY, GEN_VIRT_HOSTS, HOSTNAMES_PROP_KEY, LIBRESOURCE_REPO_CLASS_PROP_VAL, LIBRESOURCE_REPO_URL_PROP_VAL, MONITOR_CLASS_NAME, MONITOR_CLUST_CLASS_NAME, MONITORING, MYSQL_REPO_CLASS_PROP_VAL, MYSQL_REPO_URL_PROP_VAL, PGSQL_REPO_CLASS_PROP_VAL, PGSQL_REPO_URL_PROP_VAL, ROUTER_COMP_CLASS_NAME, S2S_CLUST_COMP_CLASS_NAME, S2S_COMP_CLASS_NAME, SHARED_AUTH_REPO_PARAMS_PROP_KEY, SHARED_AUTH_REPO_PROP_KEY, SHARED_USER_REPO_PARAMS_PROP_KEY, SHARED_USER_REPO_PROP_KEY, SM_CLUST_COMP_CLASS_NAME, SM_COMP_CLASS_NAME, SRECV_COMP_CLASS_NAME, SSEND_COMP_CLASS_NAME, STANZA_WHITE_CHAR_ACK, STANZA_XMPP_ACK, STATS_CLASS_NAME, STRINGPREP_PROCESSOR, TIGASE_AUTH_REPO_CLASS_PROP_VAL, TIGASE_AUTH_REPO_URL_PROP_VAL, TIGASE_CUSTOM_AUTH_REPO_CLASS_PROP_VAL, TRUSTED_PROP_KEY, USER_DOMAIN_POOL_CLASS, USER_REPO_DOMAINS_PROP_KEY, USER_REPO_PARAMS_NODE, USER_REPO_POOL_CLASS, USER_REPO_POOL_SIZE, USER_REPO_POOL_SIZE_PROP_KEY, USER_REPO_URL_PROP_KEY, VHOST_MAN_CLASS_NAME, VHOST_MAN_CLUST_CLASS_NAME, WS2S_CLASS_NAME, WS2S_CLUST_CLASS_NAME, XML_REPO_CLASS_PROP_VAL, XML_REPO_URL_PROP_VAL, XMPP_STANZA_ACK

Fields inherited from interface tigase.disco.XMPPService
CMD_FEATURES, DEF_FEATURES, INFO_XMLNS, ITEMS_XMLNS

Constructor Summary

Constructors
Constructor and Description

ConnectionManager()

Constructors
Constructor and Description
`ConnectionManager()`

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method and Description
`protected void`	`addWaitingTask(Map<String,Object> conn)`
`protected <T> void`	`checkHighThroughputProperty(String ht_def_key, T ht_dev_val, String st_def_key, T st_def_val, String prop_key, Class<T> prop_val_class, Map<String,Object> params, Map<String,Object> props)` Method description
`boolean`	`checkTrafficLimits(IO serv)`
`protected void`	`connectWaitingTasks()`
`protected int`	`countIOServices()` Returns number of active network connections (IOServices).
`protected void`	`doForAllServices(ServiceChecker<IO> checker)` Perform a given action defined by ServiceChecker for all active IOService objects (active network connections).
`void`	`everyMinute()` Utility method executed precisely every minute.
`Map<String,Object>`	`getDefaults(Map<String,Object> params)` Returns default configuration settings for the component as a `Map` with keys as configuration property IDs and values as the configuration property values.
`protected int[]`	`getDefPlainPorts()` Method description
`protected int[]`	`getDefSSLPorts()` Method description
`protected String`	`getDefTrafficThrottling()` Method description
`protected abstract long`	`getMaxInactiveTime()` Method description
`protected Map<String,Object>`	`getParamsForPort(int port)` Method description
`protected String`	`getServiceId(JID jid)` Method description
`protected String`	`getServiceId(Packet packet)` Method description
`void`	`getStatistics(StatisticsList list)` Method returns component statistics.
`protected String`	`getUniqueId(IO serv)` Method description
`protected IO`	`getXMPPIOService(Packet p)` Method description
`IO`	`getXMPPIOService(String serviceId)` Method description
`protected abstract IO`	`getXMPPIOServiceInstance()` Method description
`int`	`hashCodeForPacket(Packet packet)` This method decides how incoming packets are distributed among processing threads.
`void`	`initBindings(Bindings binds)` Initialize a mapping of key/value pairs which can be used in scripts loaded by the server
`void`	`initializationCompleted()` Method is called by `MessageRouter` when all the startup components of the server have been loaded and configured through setProperties(...) call.
`protected boolean`	`isHighThroughput()` Method description
`protected ConnectionManager.Watchdog`	`newWatchdog()`
`void`	`packetsReady(IO serv)`
`int`	`processingInThreads()` Concurrency control method.
`int`	`processingOutThreads()` Concurrency control method.
`void`	`processPacket(Packet packet)` This is the main `Packet` processing method.
`abstract Queue<Packet>`	`processSocketData(IO serv)`
`abstract boolean`	`processUndeliveredPacket(Packet packet, Long stamp, String errorMessage)` Processes undelivered packets
`abstract void`	`reconnectionFailed(Map<String,Object> port_props)`
`void`	`release()` Method description
`void`	`serviceStarted(IO service)`
`boolean`	`serviceStopped(IO service)`
`void`	`setName(String name)` Method description
`void`	`setProperties(Map<String,Object> props)` Sets all configuration properties for the object.
`protected void`	`setupWatchdogThread()`
`protected void`	`socketAccepted(IO serv, SocketType type)`
`void`	`stop()` Method description
`void`	`updateConnectionDetails(Map<String,Object> port_props)`
`void`	`writePacketsToSocket(IO serv, Queue<Packet> packets)`
`boolean`	`writePacketToSocket(IO ios, Packet p)` Method description
`protected boolean`	`writePacketToSocket(Packet p)`
`protected boolean`	`writePacketToSocket(Packet p, String serviceId)` Method description
`protected void`	`writeRawData(IO ios, String data)`
`String`	`xmppStreamError(IO serv, List<Element> err_el)`

Methods inherited from class tigase.server.BasicComponent
addComponentDomain, canCallCommand, checkCommandAcl, getComponentId, getComponentInfo, getDefHostName, getDefVHostItem, getDiscoCategory, getDiscoCategoryType, getDiscoDescription, getDiscoFeatures, getDiscoFeatures, getDiscoInfo, getDiscoInfo, getDiscoItems, getDiscoItems, getName, getNodesConnected, getNodesConnectedWithLocal, getScriptCommands, getScriptItems, getServiceEntity, getVHostItem, handlesLocalDomains, handlesNameSubdomains, handlesNonLocalDomains, isAdmin, isInitializationComplete, isLocalDomain, isLocalDomainOrComponent, isNonAdminCommands, isSubdomain, isTrusted, isTrusted, nodeConnected, nodeDisconnected, onNodeConnected, onNodeDisconnected, processScriptCommand, removeComponentDomain, removeServiceDiscoveryItem, setClusterController, setVHostManager, updateServiceDiscoveryItem, updateServiceDiscoveryItem, updateServiceDiscoveryItem, updateServiceEntity

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface tigase.xmpp.XMPPIOServiceListener
xmppStreamClosed, xmppStreamOpened

Methods inherited from interface tigase.net.IOServiceListener
tlsHandshakeCompleted

Methods inherited from interface tigase.stats.StatisticsContainerIfc
getName

Methods inherited from interface tigase.server.MessageReceiver
getDefHostName

Methods inherited from interface tigase.server.ServerComponent
getComponentId, getComponentInfo, getName, isInitializationComplete

- Field Detail
  - HT_TRAFFIC_THROTTLING_PROP_KEY
```
public static final String HT_TRAFFIC_THROTTLING_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - HT_TRAFFIC_THROTTLING_PROP_VAL
```
public static final String HT_TRAFFIC_THROTTLING_PROP_VAL
```
    See Also:
    
    Constant Field Values
  - NET_BUFFER_HT_PROP_KEY
```
public static final String NET_BUFFER_HT_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - NET_BUFFER_ST_PROP_KEY
```
public static final String NET_BUFFER_ST_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - PORT_LOCAL_HOST_PROP_KEY
```
public static final String PORT_LOCAL_HOST_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - ST_TRAFFIC_THROTTLING_PROP_KEY
```
public static final String ST_TRAFFIC_THROTTLING_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - ST_TRAFFIC_THROTTLING_PROP_VAL
```
public static final String ST_TRAFFIC_THROTTLING_PROP_VAL
```
    See Also:
    
    Constant Field Values
  - TRAFFIC_THROTTLING_PROP_KEY
```
public static final String TRAFFIC_THROTTLING_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - LAST_MINUTE_BIN_LIMIT_PROP_VAL
```
protected static final long LAST_MINUTE_BIN_LIMIT_PROP_VAL
```
    See Also:
    
    Constant Field Values
  - LAST_MINUTE_PACKETS_LIMIT_PROP_VAL
```
protected static final long LAST_MINUTE_PACKETS_LIMIT_PROP_VAL
```
    See Also:
    
    Constant Field Values
  - MAX_INACTIVITY_TIME
```
protected static final String MAX_INACTIVITY_TIME
```
    See Also:
    
    Constant Field Values
  - MAX_RECONNECTS_PROP_KEY
```
protected static final String MAX_RECONNECTS_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - NET_BUFFER_HT_PROP_VAL
```
protected static final int NET_BUFFER_HT_PROP_VAL
```
    See Also:
    
    Constant Field Values
  - NET_BUFFER_PROP_KEY
```
protected static final String NET_BUFFER_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - NET_BUFFER_ST_PROP_VAL
```
protected static final int NET_BUFFER_ST_PROP_VAL
```
    See Also:
    
    Constant Field Values
  - NET_BUFFER_LIMIT_HT_PROP_VAL
```
protected static final int NET_BUFFER_LIMIT_HT_PROP_VAL
```
    See Also:
    
    Constant Field Values
  - NET_BUFFER_LIMIT_PROP_KEY
```
protected static final String NET_BUFFER_LIMIT_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - NET_BUFFER_LIMIT_ST_PROP_VAL
```
protected static final int NET_BUFFER_LIMIT_ST_PROP_VAL
```
    See Also:
    
    Constant Field Values
  - ELEMENTS_NUMBER_LIMIT_PROP_KEY
```
public static final String ELEMENTS_NUMBER_LIMIT_PROP_KEY
```
    Key name of the system property for configuration protection from system overload and DOS attack.
    
    See Also:
    
    Constant Field Values
  - ELEMENTS_NUMBER_LIMIT_PROP_VAL
```
public static int ELEMENTS_NUMBER_LIMIT_PROP_VAL
```
    Default value for the system property for configuration protection from system overload and DOS attack.
  - PORT_CLASS_PROP_KEY
```
protected static final String PORT_CLASS_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - PORT_IFC_PROP_KEY
```
protected static final String PORT_IFC_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - PORT_LISTENING_DELAY_KEY
```
protected static final String PORT_LISTENING_DELAY_KEY
```
    See Also:
    
    Constant Field Values
  - PORT_LISTENING_DELAY_DEF
```
protected static final boolean PORT_LISTENING_DELAY_DEF
```
    See Also:
    
    Constant Field Values
  - PORT_KEY
```
protected static final String PORT_KEY
```
    See Also:
    
    Constant Field Values
  - PORT_REMOTE_HOST_PROP_KEY
```
protected static final String PORT_REMOTE_HOST_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - PORT_REMOTE_HOST_PROP_VAL
```
protected static final String PORT_REMOTE_HOST_PROP_VAL
```
    See Also:
    
    Constant Field Values
  - PORT_SOCKET_PROP_KEY
```
protected static final String PORT_SOCKET_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - PORT_TYPE_PROP_KEY
```
protected static final String PORT_TYPE_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - PROP_KEY
```
protected static final String PROP_KEY
```
    See Also:
    
    Constant Field Values
  - TOTAL_BIN_LIMIT_PROP_VAL
```
protected static final long TOTAL_BIN_LIMIT_PROP_VAL
```
    See Also:
    
    Constant Field Values
  - TOTAL_PACKETS_LIMIT_PROP_VAL
```
protected static final long TOTAL_PACKETS_LIMIT_PROP_VAL
```
    See Also:
    
    Constant Field Values
  - WHITE_CHAR_ACK_PROP_KEY
```
protected static final String WHITE_CHAR_ACK_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - XMPP_ACK_PROP_KEY
```
protected static final String XMPP_ACK_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - XMPP_ACK_PROP_VAL
```
protected static final boolean XMPP_ACK_PROP_VAL
```
    See Also:
    
    Constant Field Values
  - WHITE_CHAR_ACK_PROP_VAL
```
protected static final boolean WHITE_CHAR_ACK_PROP_VAL
```
    See Also:
    
    Constant Field Values
  - PORTS_PROP_KEY
```
protected static final String PORTS_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - TLS_USE_PROP_VAL
```
protected static final boolean TLS_USE_PROP_VAL
```
    See Also:
    
    Constant Field Values
  - TLS_PROP_KEY
```
protected static final String TLS_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - TLS_USE_PROP_KEY
```
protected static final String TLS_USE_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - TLS_REQUIRED_PROP_VAL
```
protected static final boolean TLS_REQUIRED_PROP_VAL
```
    See Also:
    
    Constant Field Values
  - TLS_REQUIRED_PROP_KEY
```
protected static final String TLS_REQUIRED_PROP_KEY
```
    See Also:
    
    Constant Field Values
  - WATCHDOG_DELAY
```
protected static final String WATCHDOG_DELAY
```
    See Also:
    
    Constant Field Values
  - WATCHDOG_TIMEOUT
```
protected static final String WATCHDOG_TIMEOUT
```
    See Also:
    
    Constant Field Values
  - WATCHDOG_PING_TYPE_KEY
```
protected static final String WATCHDOG_PING_TYPE_KEY
```
    See Also:
    
    Constant Field Values
  - pingElement
```
protected static final Element pingElement
```
  - PORT_IFC_PROP_VAL
```
public String[] PORT_IFC_PROP_VAL
```
  - watchdogDelay
```
protected long watchdogDelay
```
  - watchdogTimeout
```
protected long watchdogTimeout
```
  - elements_number_limit
```
protected int elements_number_limit
```
    Protection from the system overload and DOS attack. We want to limit number of elements created within a single XMPP stanza.
  - processors
```
protected XMPPIOProcessor[] processors
```
  - net_buffer
```
protected int net_buffer
```
  - connectionDelay
```
protected long connectionDelay
```
  - watchdogPingType
```
protected ConnectionManager.WATCHDOG_PING_TYPE watchdogPingType
```
  - delayPortListening
```
protected boolean delayPortListening
```
- Constructor Detail
  - ConnectionManager
```
public ConnectionManager()
```
- Method Detail
  - checkTrafficLimits
```
public boolean checkTrafficLimits(IO serv)
```
  - everyMinute
```
public void everyMinute()
```
    Description copied from class: AbstractMessageReceiver
    
    Utility method executed precisely every minute. A component can overwrite the method to put own code to be executed at the regular intervals of time.
    Note, no extensive calculations should happen in this method nor long lasting operations. It is essential that the method processing does not exceed 1 minute. The overriding method must call the the super method first and only then run own code.
    
    Overrides:
    
    everyMinute in class AbstractMessageReceiver
  - hashCodeForPacket
```
public int hashCodeForPacket(Packet packet)
```
    Description copied from class: AbstractMessageReceiver
    This method decides how incoming packets are distributed among processing threads. Different components needs different distribution to efficient use all threads and avoid packets re-ordering.
    If there are N processing threads, packets are distributed among threads using following code:
```
 int threadNo = Math.abs(hashCodeForPacket(packet) % N);
 
```
    For a PubSub component, for example, a better packets distribution would be based on the PubSub channel name, for SM a better distribution is based on the destination address, etc....
    Overrides:
    
    hashCodeForPacket in class AbstractMessageReceiver
    
    Parameters:
    
    packet - is a Packet which needs to be processed by some thread.
    
    Returns:
    
    a hash code generated for the input thread.
  - initBindings
```
public void initBindings(Bindings binds)
```
    Description copied from class: BasicComponent
    
    Initialize a mapping of key/value pairs which can be used in scripts loaded by the server
    
    Overrides:
    
    initBindings in class BasicComponent
    
    Parameters:
    
    binds - A mapping of key/value pairs, all of whose keys are Strings.
  - initializationCompleted
```
public void initializationCompleted()
```
    Description copied from interface: ServerComponent
    
    Method is called by MessageRouter when all the startup components of the server have been loaded and configured through setProperties(...) call. At this point the whole server should be loaded and functional, except initializations taking place in this routine.
    
    Specified by:
    
    initializationCompleted in interface ServerComponent
    
    Overrides:
    
    initializationCompleted in class BasicComponent
  - connectWaitingTasks
```
protected void connectWaitingTasks()
```
  - packetsReady
```
public void packetsReady(IO serv)
                  throws IOException
```
    Specified by:
    
    packetsReady in interface IOServiceListener<IO extends XMPPIOService<?>>
    
    Throws:
    
    IOException
  - processingInThreads
```
public int processingInThreads()
```
    Description copied from class: AbstractMessageReceiver
    
    Concurrency control method. Returns preferable number of threads set for this component.
    
    Overrides:
    
    processingInThreads in class AbstractMessageReceiver
    
    Returns:
    
    preferable number of threads set for this component.
  - processingOutThreads
```
public int processingOutThreads()
```
    Description copied from class: AbstractMessageReceiver
    
    Concurrency control method. Returns preferable number of threads set for this component.
    
    Overrides:
    
    processingOutThreads in class AbstractMessageReceiver
    
    Returns:
    
    preferable number of threads set for this component.
  - processPacket
```
public void processPacket(Packet packet)
```
    Description copied from class: AbstractMessageReceiver
    
    This is the main Packet processing method. It is called concurrently from many threads so implementing it in thread save manner is essential. The method is called for each packet addressed to the component.
    Please note, the Packet instance may be processed by different parts of the server, different components or plugins at the same time. Therefore this is very important to tread the Packet instance as unmodifiable object.
    Processing in this method is asynchronous, therefore there is no result value. If there are some 'result' packets generated during processing, they should be passed back using addOutPacket(Packet) method.
    
    Specified by:
    
    processPacket in class AbstractMessageReceiver
    
    Parameters:
    
    packet - is an instance of the Packet class passed for processing.
  - processSocketData
```
public abstract Queue<Packet> processSocketData(IO serv)
```
  - processUndeliveredPacket
```
public abstract boolean processUndeliveredPacket(Packet packet,
                                                 Long stamp,
                                                 String errorMessage)
```
    Processes undelivered packets
    
    Parameters:
    
    packet -
    
    stamp - - timestamp when packet was received to be written to XMPPIOService
    
    errorMessage -
  - reconnectionFailed
```
public abstract void reconnectionFailed(Map<String,Object> port_props)
```
  - release
```
public void release()
```
    Description copied from interface: ServerComponent
    
    Method description
    
    Specified by:
    
    release in interface ServerComponent
    
    Overrides:
    
    release in class AbstractMessageReceiver
  - serviceStarted
```
@TODO(note="Do something if service with the same unique ID is already started, possibly kill the old one...")
public void serviceStarted(IO service)
```
  - serviceStopped
```
public boolean serviceStopped(IO service)
```
    Specified by:
    
    serviceStopped in interface IOServiceListener<IO extends XMPPIOService<?>>
  - stop
```
public void stop()
```
    Description copied from class: AbstractMessageReceiver
    
    Method description
    
    Overrides:
    
    stop in class AbstractMessageReceiver
  - updateConnectionDetails
```
public void updateConnectionDetails(Map<String,Object> port_props)
```
  - writePacketsToSocket
```
public void writePacketsToSocket(IO serv,
                                 Queue<Packet> packets)
```
  - writePacketToSocket
```
public boolean writePacketToSocket(IO ios,
                                   Packet p)
```
    Method description
    
    Parameters:
    
    ios -
    
    p -
    
    Returns:
    
    a value of boolean
  - xmppStreamError
```
public String xmppStreamError(IO serv,
                              List<Element> err_el)
```
    Specified by:
    
    xmppStreamError in interface XMPPIOServiceListener<IO extends XMPPIOService<?>>
  - getDefaults
```
public Map<String,Object> getDefaults(Map<String,Object> params)
```
    Description copied from class: AbstractMessageReceiver
    
    Returns default configuration settings for the component as a Map with keys as configuration property IDs and values as the configuration property values. All the default parameters returned from this method are later passed to the setProperties(...) method. Some of them may have changed value if they have been overwritten in the server configuration. The configuration property value can be of any of the basic types: int, long, boolean, String.
    
    Specified by:
    
    getDefaults in interface Configurable
    
    Overrides:
    
    getDefaults in class AbstractMessageReceiver
    
    Parameters:
    
    params - is a Map with some initial properties set for the starting up server. These parameters can be used as a hints to generate component's default configuration.
    
    Returns:
    
    a Map with the component default configuration.
  - getStatistics
```
public void getStatistics(StatisticsList list)
```
    Description copied from class: AbstractMessageReceiver
    Method returns component statistics. Please note, the method can be called every second by the server monitoring system therefore no extensive or lengthy calculations are allowed. If there are some statistics requiring lengthy operations like database access they must have Level.FINEST assigned and must be put inside the level guard to prevent generating them by the system monitor. The system monitor does not collect FINEST statistics.
    Level guard code looks like the example below:
```
 if (list.checkLevel(Level.FINEST)) {
   // Some CPU intensive calculations or lengthy operations
   list.add(getName(), "Statistic description", stat_value, Level.FINEST);
 }

 
```
    This way you make sure your extensive operation is not executed every second by the monitoring system and does not affect the server performance.
    Specified by:
    
    getStatistics in interface StatisticsContainerIfc
    
    Overrides:
    
    getStatistics in class AbstractMessageReceiver
    
    Parameters:
    
    list - is a StatistcsList where all statistics are stored.
  - getXMPPIOService
```
public IO getXMPPIOService(String serviceId)
```
    Method description
    
    Parameters:
    
    serviceId -
    
    Returns:
    
    a value of IO
  - setName
```
public void setName(String name)
```
    Description copied from interface: ServerComponent
    
    Method description
    
    Specified by:
    
    setName in interface ServerComponent
    
    Overrides:
    
    setName in class AbstractMessageReceiver
  - setupWatchdogThread
```
protected void setupWatchdogThread()
```
  - newWatchdog
```
protected ConnectionManager.Watchdog newWatchdog()
```
  - setProperties
```
public void setProperties(Map<String,Object> props)
                   throws ConfigurationException
```
    Description copied from interface: Configurable
    
    Sets all configuration properties for the object.
    
    Specified by:
    
    setProperties in interface Configurable
    
    Overrides:
    
    setProperties in class AbstractMessageReceiver
    
    Parameters:
    
    props - Map with the configuration
    
    Throws:
    
    ConfigurationException - - if setting configuration will fail which will make it unable to work
  - addWaitingTask
```
protected void addWaitingTask(Map<String,Object> conn)
```
  - checkHighThroughputProperty
```
protected <T> void checkHighThroughputProperty(String ht_def_key,
                                               T ht_dev_val,
                                               String st_def_key,
                                               T st_def_val,
                                               String prop_key,
                                               Class<T> prop_val_class,
                                               Map<String,Object> params,
                                               Map<String,Object> props)
```
    Method description
    
    Type Parameters:
    
    T -
    
    Parameters:
    
    ht_def_key -
    
    ht_dev_val -
    
    st_def_key -
    
    st_def_val -
    
    prop_key -
    
    prop_val_class -
    
    params -
    
    props -
  - countIOServices
```
protected int countIOServices()
```
    Returns number of active network connections (IOServices).
    
    Returns:
    
    number of active network connections (IOServices).
  - doForAllServices
```
protected void doForAllServices(ServiceChecker<IO> checker)
```
    Perform a given action defined by ServiceChecker for all active IOService objects (active network connections).
    
    Parameters:
    
    checker - is a ServiceChecker instance defining an action to perform for all IOService objects.
  - writePacketToSocket
```
protected boolean writePacketToSocket(Packet p)
```
    Parameters:
    
    p -
    
    Returns:
    
    a value of boolean
  - writePacketToSocket
```
protected boolean writePacketToSocket(Packet p,
                                      String serviceId)
```
    Method description
    
    Parameters:
    
    p -
    
    serviceId -
    
    Returns:
    
    a value of boolean
  - writeRawData
```
protected void writeRawData(IO ios,
                            String data)
```
  - getDefPlainPorts
```
protected int[] getDefPlainPorts()
```
    Method description
    
    Returns:
    
    a value of int[]
  - getDefSSLPorts
```
protected int[] getDefSSLPorts()
```
    Method description
    
    Returns:
    
    a value of int[]
  - getDefTrafficThrottling
```
protected String getDefTrafficThrottling()
```
    Method description
    
    Returns:
    
    a value of String
  - getMaxInactiveTime
```
protected abstract long getMaxInactiveTime()
```
    Method description
    
    Returns:
    
    a value of long
  - getParamsForPort
```
protected Map<String,Object> getParamsForPort(int port)
```
    Method description
    
    Parameters:
    
    port -
    
    Returns:
    
    a value of Map<String,Object>
  - getServiceId
```
protected String getServiceId(Packet packet)
```
    Method description
    
    Parameters:
    
    packet -
    
    Returns:
    
    a value of String
  - getServiceId
```
protected String getServiceId(JID jid)
```
    Method description
    
    Parameters:
    
    jid -
    
    Returns:
    
    a value of String
  - getUniqueId
```
protected String getUniqueId(IO serv)
```
    Method description
    
    Parameters:
    
    serv -
    
    Returns:
    
    a value of String
  - getXMPPIOService
```
protected IO getXMPPIOService(Packet p)
```
    Method description
    
    Parameters:
    
    p -
    
    Returns:
    
    a value of IO
  - getXMPPIOServiceInstance
```
protected abstract IO getXMPPIOServiceInstance()
```
    Method description
    
    Returns:
    
    a value of IO
  - isHighThroughput
```
protected boolean isHighThroughput()
```
    Method description
    
    Returns:
    
    a value of boolean
  - socketAccepted
```
protected void socketAccepted(IO serv,
                              SocketType type)
```

Class ConnectionManager<IO extends XMPPIOService<?>>

Nested Class Summary

Field Summary

Fields inherited from class tigase.server.AbstractMessageReceiver

Fields inherited from class tigase.server.BasicComponent

Fields inherited from interface tigase.conf.Configurable

Fields inherited from interface tigase.disco.XMPPService

Constructor Summary

Method Summary

Methods inherited from class tigase.server.AbstractMessageReceiver

Methods inherited from class tigase.server.BasicComponent

Methods inherited from class java.lang.Object

Methods inherited from interface tigase.xmpp.XMPPIOServiceListener

Methods inherited from interface tigase.net.IOServiceListener

Methods inherited from interface tigase.stats.StatisticsContainerIfc

Methods inherited from interface tigase.server.MessageReceiver

Methods inherited from interface tigase.server.ServerComponent

Field Detail

HT_TRAFFIC_THROTTLING_PROP_KEY

HT_TRAFFIC_THROTTLING_PROP_VAL

NET_BUFFER_HT_PROP_KEY

NET_BUFFER_ST_PROP_KEY

PORT_LOCAL_HOST_PROP_KEY

ST_TRAFFIC_THROTTLING_PROP_KEY

ST_TRAFFIC_THROTTLING_PROP_VAL

TRAFFIC_THROTTLING_PROP_KEY

LAST_MINUTE_BIN_LIMIT_PROP_VAL

LAST_MINUTE_PACKETS_LIMIT_PROP_VAL

MAX_INACTIVITY_TIME

MAX_RECONNECTS_PROP_KEY

NET_BUFFER_HT_PROP_VAL

NET_BUFFER_PROP_KEY

NET_BUFFER_ST_PROP_VAL

NET_BUFFER_LIMIT_HT_PROP_VAL

NET_BUFFER_LIMIT_PROP_KEY

NET_BUFFER_LIMIT_ST_PROP_VAL

ELEMENTS_NUMBER_LIMIT_PROP_KEY

ELEMENTS_NUMBER_LIMIT_PROP_VAL

PORT_CLASS_PROP_KEY

PORT_IFC_PROP_KEY

PORT_LISTENING_DELAY_KEY

PORT_LISTENING_DELAY_DEF

PORT_KEY

PORT_REMOTE_HOST_PROP_KEY

PORT_REMOTE_HOST_PROP_VAL

PORT_SOCKET_PROP_KEY

PORT_TYPE_PROP_KEY

PROP_KEY

TOTAL_BIN_LIMIT_PROP_VAL

TOTAL_PACKETS_LIMIT_PROP_VAL

WHITE_CHAR_ACK_PROP_KEY

XMPP_ACK_PROP_KEY

XMPP_ACK_PROP_VAL

WHITE_CHAR_ACK_PROP_VAL

PORTS_PROP_KEY

TLS_USE_PROP_VAL

TLS_PROP_KEY

TLS_USE_PROP_KEY

TLS_REQUIRED_PROP_VAL

TLS_REQUIRED_PROP_KEY

WATCHDOG_DELAY

WATCHDOG_TIMEOUT

WATCHDOG_PING_TYPE_KEY

pingElement

PORT_IFC_PROP_VAL

watchdogDelay

watchdogTimeout

elements_number_limit

processors

net_buffer

connectionDelay

watchdogPingType

delayPortListening

Constructor Detail

ConnectionManager

Method Detail

checkTrafficLimits

everyMinute

hashCodeForPacket

initBindings