public class ComponentProtocol extends ConnectionManager<ComponentIOService> implements ComponentProtocolHandler
ConnectionManager.LIMIT_ACTION, ConnectionManager.WATCHDOG_PING_TYPE
Modifier and Type | Field and Description |
---|---|
static String |
AUTHENTICATION_TIMEOUT_PROP_KEY
Field description
|
static String |
CLOSE_ON_SEQUENCE_ERROR_PROP_KEY
Field description
|
static String |
EXTCOMP_BIND_HOSTNAMES
Field description
|
static String |
EXTCOMP_REPO_CLASS_PROP_KEY
Field description
|
static String |
EXTCOMP_REPO_CLASS_PROP_VAL
Field description
|
static String |
EXTCOMP_REPO_CLASS_PROPERTY
Field description
|
static String |
IDENTITY_TYPE_KEY
Field description
|
static String |
IDENTITY_TYPE_VAL
Field description
|
static String |
MAX_AUTH_ATTEMPTS_PROP_KEY
Field description
|
static String |
PACK_ROUTED_KEY
Field description
|
boolean |
PACK_ROUTED_VAL
Field description
|
static String |
RETURN_SERVICE_DISCO_KEY
Field description
|
static boolean |
RETURN_SERVICE_DISCO_VAL
Field description
|
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
EXTCOMP_BIND_HOSTNAMES_PROP_KEY, REPO_ITEM_KEY
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 |
---|
ComponentProtocol()
Constructs ...
|
Modifier and Type | Method and Description |
---|---|
void |
authenticated(ComponentIOService serv)
Method description
|
void |
authenticationFailed(ComponentIOService serv,
Packet packet)
Method description
|
void |
bindHostname(String hostname,
ComponentIOService serv)
Method description
|
CompRepoItem |
getCompRepoItem(String hostname)
Method description
|
Map<String,Object> |
getDefaults(Map<String,Object> params)
Method description
|
protected String |
getDefTrafficThrottling()
Method description
|
String |
getDiscoCategoryType()
Method description
|
String |
getDiscoDescription()
Method description
|
protected long |
getMaxInactiveTime()
Method description
|
protected Integer |
getMaxQueueSize(int def)
Method description
|
ExtProcessor |
getProcessor(String key)
Method description
|
void |
getStatistics(StatisticsList list)
Method description
|
List<tigase.xml.Element> |
getStreamFeatures(ComponentIOService serv)
Method description
|
StreamOpenHandler |
getStreamOpenHandler(String xmlns)
Method description
|
protected ComponentIOService |
getXMPPIOService(Packet p)
Method description
|
protected ComponentIOService |
getXMPPIOServiceInstance()
Method description
|
void |
initBindings(Bindings binds)
Method description
|
protected boolean |
isHighThroughput()
Method description
|
Queue<Packet> |
processSocketData(ComponentIOService serv)
Method description
|
void |
reconnectionFailed(Map<String,Object> port_props)
Method description
|
void |
serviceStarted(ComponentIOService serv)
Method description
|
boolean |
serviceStopped(ComponentIOService service)
Method description
|
void |
setProperties(Map<String,Object> properties)
Method description
|
void |
tlsHandshakeCompleted(ComponentIOService service)
Method description
|
void |
unbindHostname(String hostname,
ComponentIOService serv)
Method description
|
boolean |
writePacketToSocket(ComponentIOService ios,
Packet p)
Method description
|
void |
xmppStreamClosed(ComponentIOService serv)
Method description
|
String |
xmppStreamOpened(ComponentIOService serv,
Map<String,String> attribs)
Method description
|
addWaitingTask, checkHighThroughputProperty, checkTrafficLimits, countIOServices, doForAllServices, everyMinute, getDefPlainPorts, getDefSSLPorts, getParamsForPort, getServiceId, getServiceId, getUniqueId, getXMPPIOService, hashCodeForPacket, initializationCompleted, isTlsWantClientAuthEnabled, packetsReady, processingInThreads, processingOutThreads, processPacket, processUndeliveredPacket, release, setName, setupWatchdogThread, stop, updateConnectionDetails, writePacketsToSocket, writePacketToSocket, writePacketToSocket, writeRawData
addOutPacket, addOutPacketNB, addOutPackets, addOutPacketWithTimeout, addPacket, addPacketNB, addPackets, addRegexRouting, addTimerTask, addTimerTask, addTimerTask, addTimerTask, clearRegexRoutings, everyHour, everySecond, getRegexRoutings, isInRegexRoutings, newPacketId, processingThreads, processOutPacket, processPacket, removeRegexRouting, schedulerThreads, setMaxQueueSize, setParent, start
addComponentDomain, canCallCommand, checkCommandAcl, getComponentId, getComponentInfo, getDefHostName, getDefVHostItem, getDiscoCategory, getDiscoFeatures, getDiscoFeatures, getDiscoInfo, getDiscoInfo, getDiscoItems, getDiscoItems, getName, getScriptCommands, getScriptItems, getServiceEntity, getVHostItem, handlesLocalDomains, handlesNameSubdomains, handlesNonLocalDomains, 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
newPacketId
getDefHostName
getComponentId, getComponentInfo, getName, isInitializationComplete
public static final String AUTHENTICATION_TIMEOUT_PROP_KEY
public static final String CLOSE_ON_SEQUENCE_ERROR_PROP_KEY
public static final String EXTCOMP_BIND_HOSTNAMES
public static final String EXTCOMP_REPO_CLASS_PROP_KEY
public static final String EXTCOMP_REPO_CLASS_PROP_VAL
public static final String EXTCOMP_REPO_CLASS_PROPERTY
public static final String IDENTITY_TYPE_KEY
public static final String IDENTITY_TYPE_VAL
public static final String MAX_AUTH_ATTEMPTS_PROP_KEY
public static final String PACK_ROUTED_KEY
public static final String RETURN_SERVICE_DISCO_KEY
public static final boolean RETURN_SERVICE_DISCO_VAL
public boolean PACK_ROUTED_VAL
public void authenticated(ComponentIOService serv)
authenticated
in interface ComponentProtocolHandler
serv
- public void authenticationFailed(ComponentIOService serv, Packet packet)
authenticationFailed
in interface ComponentProtocolHandler
serv
- packet
- protected String getDefTrafficThrottling()
getDefTrafficThrottling
in class ConnectionManager<ComponentIOService>
String
public void bindHostname(String hostname, ComponentIOService serv)
bindHostname
in interface ComponentProtocolHandler
hostname
- serv
- public CompRepoItem getCompRepoItem(String hostname)
getCompRepoItem
in interface ComponentProtocolHandler
hostname
- public Map<String,Object> getDefaults(Map<String,Object> params)
getDefaults
in interface Configurable
getDefaults
in class ConnectionManager<ComponentIOService>
params
- Map
with the component default configuration.public String getDiscoCategoryType()
getDiscoCategoryType
in class BasicComponent
String
public String getDiscoDescription()
getDiscoDescription
in class BasicComponent
String
public ExtProcessor getProcessor(String key)
getProcessor
in interface ComponentProtocolHandler
key
- public void getStatistics(StatisticsList list)
getStatistics
in interface StatisticsContainer
getStatistics
in class ConnectionManager<ComponentIOService>
list
- public List<tigase.xml.Element> getStreamFeatures(ComponentIOService serv)
getStreamFeatures
in interface ComponentProtocolHandler
serv
- public StreamOpenHandler getStreamOpenHandler(String xmlns)
getStreamOpenHandler
in interface ComponentProtocolHandler
xmlns
- public void initBindings(Bindings binds)
initBindings
in class ConnectionManager<ComponentIOService>
binds
- public Queue<Packet> processSocketData(ComponentIOService serv)
processSocketData
in class ConnectionManager<ComponentIOService>
serv
- Queue
public void reconnectionFailed(Map<String,Object> port_props)
reconnectionFailed
in class ConnectionManager<ComponentIOService>
port_props
- public void serviceStarted(ComponentIOService serv)
serviceStarted
in class ConnectionManager<ComponentIOService>
serv
- public boolean serviceStopped(ComponentIOService service)
serviceStopped
in interface IOServiceListener<ComponentIOService>
serviceStopped
in class ConnectionManager<ComponentIOService>
service
- public void setProperties(Map<String,Object> properties) throws ConfigurationException
setProperties
in interface Configurable
setProperties
in class ConnectionManager<ComponentIOService>
properties
- ConfigurationException
public void tlsHandshakeCompleted(ComponentIOService service)
tlsHandshakeCompleted
in interface IOServiceListener<ComponentIOService>
service
- public void unbindHostname(String hostname, ComponentIOService serv)
unbindHostname
in interface ComponentProtocolHandler
hostname
- serv
- public boolean writePacketToSocket(ComponentIOService ios, Packet p)
writePacketToSocket
in class ConnectionManager<ComponentIOService>
ios
- p
- boolean
public void xmppStreamClosed(ComponentIOService serv)
xmppStreamClosed
in interface XMPPIOServiceListener<ComponentIOService>
serv
- public String xmppStreamOpened(ComponentIOService serv, Map<String,String> attribs)
xmppStreamOpened
in interface XMPPIOServiceListener<ComponentIOService>
serv
- attribs
- protected long getMaxInactiveTime()
getMaxInactiveTime
in class ConnectionManager<ComponentIOService>
long
protected Integer getMaxQueueSize(int def)
getMaxQueueSize
in class AbstractMessageReceiver
def
- Integer
protected ComponentIOService getXMPPIOService(Packet p)
getXMPPIOService
in class ConnectionManager<ComponentIOService>
p
- IO
protected ComponentIOService getXMPPIOServiceInstance()
getXMPPIOServiceInstance
in class ConnectionManager<ComponentIOService>
IO
protected boolean isHighThroughput()
isHighThroughput
in class ConnectionManager<ComponentIOService>
boolean
Copyright © 2014 "Tigase, Inc.". All rights reserved.