public class S2SConnectionManager extends ConnectionManager<S2SIOService> implements S2SConnectionHandlerIfc<S2SIOService>
Modifier and Type | Class and Description |
---|---|
protected static class |
S2SConnectionManager.DomainServerNameMapper |
ConnectionManager.LIMIT_ACTION, ConnectionManager.WATCHDOG_PING_TYPE
connectionDelay, elements_number_limit, ELEMENTS_NUMBER_LIMIT_PROP_KEY, ELEMENTS_NUMBER_LIMIT_PROP_VAL, HT_TRAFFIC_THROTTLING_PROP_KEY, HT_TRAFFIC_THROTTLING_PROP_VAL, LAST_MINUTE_BIN_LIMIT_PROP_VAL, LAST_MINUTE_PACKETS_LIMIT_PROP_VAL, MAX_INACTIVITY_TIME, MAX_RECONNECTS_PROP_KEY, net_buffer, NET_BUFFER_HT_PROP_KEY, NET_BUFFER_HT_PROP_VAL, NET_BUFFER_LIMIT_HT_PROP_VAL, NET_BUFFER_LIMIT_PROP_KEY, NET_BUFFER_LIMIT_ST_PROP_VAL, NET_BUFFER_PROP_KEY, NET_BUFFER_ST_PROP_KEY, NET_BUFFER_ST_PROP_VAL, pingElement, PORT_CLASS_PROP_KEY, PORT_IFC_PROP_KEY, PORT_IFC_PROP_VAL, PORT_KEY, PORT_LOCAL_HOST_PROP_KEY, PORT_REMOTE_HOST_PROP_KEY, PORT_REMOTE_HOST_PROP_VAL, PORT_SOCKET_PROP_KEY, PORT_TYPE_PROP_KEY, PORTS_PROP_KEY, PROP_KEY, ST_TRAFFIC_THROTTLING_PROP_KEY, ST_TRAFFIC_THROTTLING_PROP_VAL, TLS_PROP_KEY, TLS_REQUIRED_PROP_KEY, TLS_REQUIRED_PROP_VAL, TLS_USE_PROP_KEY, TLS_USE_PROP_VAL, TOTAL_BIN_LIMIT_PROP_VAL, TOTAL_PACKETS_LIMIT_PROP_VAL, TRAFFIC_THROTTLING_PROP_KEY, WATCHDOG_DELAY, WATCHDOG_PING_TYPE_KEY, WATCHDOG_TIMEOUT, watchdogDelay, watchdogPingType, watchdogTimeout, WHITE_CHAR_ACK_PROP_KEY, WHITE_CHAR_ACK_PROP_VAL, XMPP_ACK_PROP_KEY, XMPP_ACK_PROP_VAL
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, SCHEDULER_THREADS_PROP_KEY, SECOND
admins, ALL_PROP_KEY, COMMAND_PROP_NODE, scriptCommands, SCRIPTS_DIR_PROP_DEF, SCRIPTS_DIR_PROP_KEY, vHostManager
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_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, 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
CMD_FEATURES, DEF_FEATURES, INFO_XMLNS, ITEMS_XMLNS
Constructor and Description |
---|
S2SConnectionManager() |
Modifier and Type | Method and Description |
---|---|
boolean |
addOutPacket(Packet packet)
Method description
|
void |
addTimerTask(TimerTask task,
long delay,
TimeUnit unit)
Method description
|
void |
addTimerTask(TimerTask task,
long delay,
TimeUnit unit)
Deprecated.
|
CIDConnections |
getCIDConnections(CID cid,
boolean createNew)
Method description
|
Map<String,Object> |
getDefaults(Map<String,Object> params)
Method description
|
protected int[] |
getDefPlainPorts()
Method description
|
String |
getDiscoCategoryType()
Method description
|
String |
getDiscoDescription()
Method description
|
protected long |
getMaxInactiveTime()
Method description
|
String |
getSecretForDomain(String domain)
Method returns secret used for domain for generation of dialback key
|
String |
getServerNameForDomain(String domain) |
void |
getStatistics(StatisticsList list)
Method description
|
List<tigase.xml.Element> |
getStreamFeatures(S2SIOService serv)
Method description
|
protected S2SIOService |
getXMPPIOServiceInstance()
Method description
|
boolean |
handlesNonLocalDomains()
Method description
|
int |
hashCodeForPacket(Packet packet)
Method description
|
void |
initBindings(Bindings binds)
Initialize a mapping of key/value pairs which can be used in scripts
loaded by the server
|
void |
initNewConnection(Map<String,Object> port_props)
Method description
|
protected boolean |
isHighThroughput()
Method description
|
boolean |
isTlsRequired(String domain)
Checks if TLS is required for particular domain
|
boolean |
isTlsWantClientAuthEnabled()
Method description
|
void |
processPacket(Packet packet)
Method description
|
Queue<Packet> |
processSocketData(S2SIOService serv)
Method description
|
void |
reconnectionFailed(Map<String,Object> port_props)
Method description
|
int |
schedulerThreads()
Method description
|
boolean |
sendVerifyResult(String elem_name,
CID connCid,
CID keyCid,
Boolean valid,
String key_sessionId,
String serv_sessionId,
String cdata,
boolean handshakingOnly)
Method description
|
boolean |
sendVerifyResult(String elem_name,
CID connCid,
CID keyCid,
Boolean valid,
String key_sessionId,
String serv_sessionId,
String cdata,
boolean handshakingOnly,
tigase.xml.Element errorElem)
Method description
|
void |
serviceStarted(S2SIOService serv)
Method description
|
boolean |
serviceStopped(S2SIOService serv)
Method description
|
void |
setProperties(Map<String,Object> props)
Method description
|
void |
tlsHandshakeCompleted(S2SIOService serv)
Method description
|
void |
writeRawData(S2SIOService ios,
String data)
Method description
|
void |
xmppStreamClosed(S2SIOService serv)
Method description
|
String |
xmppStreamOpened(S2SIOService serv,
Map<String,String> attribs)
Method description
|
addWaitingTask, checkHighThroughputProperty, checkTrafficLimits, countIOServices, doForAllServices, everyMinute, getDefSSLPorts, getDefTrafficThrottling, getParamsForPort, getServiceId, getServiceId, getUniqueId, getXMPPIOService, getXMPPIOService, initializationCompleted, packetsReady, processingInThreads, processingOutThreads, processUndeliveredPacket, release, setName, setupWatchdogThread, stop, updateConnectionDetails, writePacketsToSocket, writePacketToSocket, writePacketToSocket, writePacketToSocket
addOutPacketNB, addOutPackets, addOutPacketWithTimeout, addPacket, addPacketNB, addPackets, addRegexRouting, addTimerTask, addTimerTask, clearRegexRoutings, everyHour, everySecond, getMaxQueueSize, getRegexRoutings, isInRegexRoutings, newPacketId, processingThreads, processOutPacket, processPacket, removeRegexRouting, setMaxQueueSize, setParent, start
addComponentDomain, canCallCommand, checkCommandAcl, getComponentId, getComponentInfo, getDefHostName, getDefVHostItem, getDiscoCategory, getDiscoFeatures, getDiscoFeatures, getDiscoInfo, getDiscoInfo, getDiscoItems, getDiscoItems, getName, getScriptCommands, getScriptItems, getServiceEntity, getVHostItem, handlesLocalDomains, handlesNameSubdomains, isAdmin, isInitializationComplete, isLocalDomain, isLocalDomainOrComponent, isNonAdminCommands, isSubdomain, processScriptCommand, removeComponentDomain, removeServiceDiscoveryItem, setVHostManager, updateServiceDiscoveryItem, updateServiceDiscoveryItem, updateServiceDiscoveryItem, updateServiceEntity
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getDefHostName, writePacketsToSocket, writePacketToSocket
getDefHostName
getComponentId, getComponentInfo, getName, isInitializationComplete
public static final String CID_CONNECTIONS_BIND
public static final String CID_CONNECTIONS_TASKS_THREADS_KEY
public static final String MAX_CONNECTION_INACTIVITY_TIME_PROP_KEY
public static final String MAX_INCOMING_CONNECTIONS_PROP_KEY
public static final int MAX_INCOMING_CONNECTIONS_PROP_VAL
public static final String MAX_OUT_PER_IP_CONNECTIONS_PROP_KEY
public static final int MAX_OUT_PER_IP_CONNECTIONS_PROP_VAL
public static final String MAX_OUT_TOTAL_CONNECTIONS_PROP_KEY
public static final int MAX_OUT_TOTAL_CONNECTIONS_PROP_VAL
public static final String MAX_PACKET_WAITING_TIME_PROP_KEY
public static final String S2S_CONNECTION_SELECTOR_PROP_KEY
public static final String S2S_CONNECTION_SELECTOR_PROP_VAL
public static final String S2S_DOMAIN_MAPPING_PROP_KEY
public static final String S2S_DOMAIN_MAPPING_PROP_VAL
protected static final String DB_RESULT_EL_NAME
protected static final String DB_VERIFY_EL_NAME
public static final long MAX_PACKET_WAITING_TIME_PROP_VAL
public static final long MAX_CONNECTION_INACTIVITY_TIME_PROP_VAL
public static final int CID_CONNECTIONS_TASKS_THREADS_VAL
public boolean addOutPacket(Packet packet)
addOutPacket
in interface S2SConnectionHandlerIfc<S2SIOService>
addOutPacket
in class AbstractMessageReceiver
packet
- boolean
public void addTimerTask(TimerTask task, long delay, TimeUnit unit)
addTimerTask
in interface S2SConnectionHandlerIfc<S2SIOService>
addTimerTask
in class AbstractMessageReceiver
task
- delay
- unit
- @Deprecated public void addTimerTask(TimerTask task, long delay, TimeUnit unit)
addTimerTask
in class AbstractMessageReceiver
task
- delay
- unit
- public boolean handlesNonLocalDomains()
handlesNonLocalDomains
in interface VHostListener
handlesNonLocalDomains
in class BasicComponent
boolean
public int hashCodeForPacket(Packet packet)
hashCodeForPacket
in class ConnectionManager<S2SIOService>
packet
- int
public void initBindings(Bindings binds)
initBindings
in class ConnectionManager<S2SIOService>
binds
- A mapping of key/value pairs, all of whose keys are Strings.public void initNewConnection(Map<String,Object> port_props)
initNewConnection
in interface S2SConnectionHandlerIfc<S2SIOService>
port_props
- public void processPacket(Packet packet)
processPacket
in class ConnectionManager<S2SIOService>
packet
- public Queue<Packet> processSocketData(S2SIOService serv)
processSocketData
in class ConnectionManager<S2SIOService>
serv
- Queue
public void reconnectionFailed(Map<String,Object> port_props)
reconnectionFailed
in class ConnectionManager<S2SIOService>
port_props
- public int schedulerThreads()
schedulerThreads
in class AbstractMessageReceiver
int
public boolean sendVerifyResult(String elem_name, CID connCid, CID keyCid, Boolean valid, String key_sessionId, String serv_sessionId, String cdata, boolean handshakingOnly)
sendVerifyResult
in interface S2SConnectionHandlerIfc<S2SIOService>
elem_name
- connCid
- keyCid
- valid
- key_sessionId
- serv_sessionId
- cdata
- handshakingOnly
- boolean
public boolean sendVerifyResult(String elem_name, CID connCid, CID keyCid, Boolean valid, String key_sessionId, String serv_sessionId, String cdata, boolean handshakingOnly, tigase.xml.Element errorElem)
sendVerifyResult
in interface S2SConnectionHandlerIfc<S2SIOService>
elem_name
- connCid
- keyCid
- valid
- key_sessionId
- serv_sessionId
- cdata
- handshakingOnly
- errorElem
- boolean
public void serviceStarted(S2SIOService serv)
serviceStarted
in class ConnectionManager<S2SIOService>
serv
- public boolean serviceStopped(S2SIOService serv)
serviceStopped
in interface IOServiceListener<S2SIOService>
serviceStopped
in class ConnectionManager<S2SIOService>
serv
- boolean
public void tlsHandshakeCompleted(S2SIOService serv)
tlsHandshakeCompleted
in interface IOServiceListener<S2SIOService>
serv
- public void writeRawData(S2SIOService ios, String data)
writeRawData
in interface S2SConnectionHandlerIfc<S2SIOService>
writeRawData
in class ConnectionManager<S2SIOService>
ios
- data
- public void xmppStreamClosed(S2SIOService serv)
xmppStreamClosed
in interface XMPPIOServiceListener<S2SIOService>
serv
- public String xmppStreamOpened(S2SIOService serv, Map<String,String> attribs)
xmppStreamOpened
in interface XMPPIOServiceListener<S2SIOService>
serv
- attribs
- String
public CIDConnections getCIDConnections(CID cid, boolean createNew) throws NotLocalhostException, LocalhostException
getCIDConnections
in interface S2SConnectionHandlerIfc<S2SIOService>
cid
- createNew
- CIDConnections
LocalhostException
NotLocalhostException
public Map<String,Object> getDefaults(Map<String,Object> params)
getDefaults
in interface Configurable
getDefaults
in class ConnectionManager<S2SIOService>
params
- Map
public String getDiscoCategoryType()
getDiscoCategoryType
in class BasicComponent
String
public String getDiscoDescription()
getDiscoDescription
in class BasicComponent
String
public String getSecretForDomain(String domain) throws NotLocalhostException
getSecretForDomain
in interface S2SConnectionHandlerIfc<S2SIOService>
domain
- NotLocalhostException
public String getServerNameForDomain(String domain)
getServerNameForDomain
in interface S2SConnectionHandlerIfc<S2SIOService>
public void getStatistics(StatisticsList list)
getStatistics
in interface StatisticsContainer
getStatistics
in class ConnectionManager<S2SIOService>
list
- public List<tigase.xml.Element> getStreamFeatures(S2SIOService serv)
getStreamFeatures
in interface S2SConnectionHandlerIfc<S2SIOService>
serv
- List
public boolean isTlsRequired(String domain)
isTlsRequired
in interface S2SConnectionHandlerIfc<S2SIOService>
domain
- public boolean isTlsWantClientAuthEnabled()
isTlsWantClientAuthEnabled
in interface S2SConnectionHandlerIfc<S2SIOService>
isTlsWantClientAuthEnabled
in class ConnectionManager<S2SIOService>
boolean
public void setProperties(Map<String,Object> props) throws ConfigurationException
setProperties
in interface Configurable
setProperties
in class ConnectionManager<S2SIOService>
props
- ConfigurationException
protected int[] getDefPlainPorts()
getDefPlainPorts
in class ConnectionManager<S2SIOService>
int[]
protected long getMaxInactiveTime()
getMaxInactiveTime
in class ConnectionManager<S2SIOService>
long
protected S2SIOService getXMPPIOServiceInstance()
getXMPPIOServiceInstance
in class ConnectionManager<S2SIOService>
S2SIOService
protected boolean isHighThroughput()
isHighThroughput
in class ConnectionManager<S2SIOService>
boolean
Copyright © 2014 "Tigase, Inc.". All rights reserved.