tigase.server.bosh
Class BoshConnectionManager

java.lang.Object
  extended by tigase.server.BasicComponent
      extended by tigase.server.AbstractMessageReceiver
          extended by tigase.server.ConnectionManager<XMPPIOService<Object>>
              extended by tigase.server.xmppclient.ClientConnectionManager
                  extended by tigase.server.bosh.BoshConnectionManager
All Implemented Interfaces:
Configurable, XMPPService, IOServiceListener<XMPPIOService<Object>>, BoshSessionTaskHandler, MessageReceiver, ServerComponent, StatisticsContainer, VHostListener, XMPPIOServiceListener<XMPPIOService<Object>>

public class BoshConnectionManager
extends ClientConnectionManager
implements BoshSessionTaskHandler

Describe class BoshConnectionManager here. Created: Sat Jun 2 12:24:29 2007

Version:
$Rev$
Author:
Artur Hefczyc

Field Summary
 
Fields inherited from class tigase.server.xmppclient.ClientConnectionManager
routings
 
Fields inherited from class tigase.server.ConnectionManager
connectionDelay, MAX_RECONNECTS_PROP_KEY, net_buffer, NET_BUFFER_HT_PROP_KEY, NET_BUFFER_HT_PROP_VAL, NET_BUFFER_PROP_KEY, NET_BUFFER_ST_PROP_KEY, NET_BUFFER_ST_PROP_VAL, 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, TLS_ALLOW_INVALID_CERTS_PROP_KEY, TLS_ALLOW_INVALID_CERTS_PROP_VAL, TLS_ALLOW_SELF_SIGNED_CERTS_PROP_KEY, TLS_ALLOW_SELF_SIGNED_CERTS_PROP_VAL, TLS_CONTAINER_CLASS_PROP_KEY, TLS_CONTAINER_CLASS_PROP_VAL, TLS_DEF_CERT_PROP_KEY, TLS_DEF_CERT_PROP_VAL, TLS_KEYS_STORE_PASSWD_PROP_KEY, TLS_KEYS_STORE_PASSWD_PROP_VAL, TLS_KEYS_STORE_PROP_KEY, TLS_KEYS_STORE_PROP_VAL, TLS_PROP_KEY, TLS_REQUIRED_PROP_KEY, TLS_REQUIRED_PROP_VAL, TLS_SERVER_CERTS_DIR_PROP_KEY, TLS_SERVER_CERTS_DIR_PROP_VAL, TLS_TRUSTED_CERTS_DIR_PROP_KEY, TLS_TRUSTED_CERTS_DIR_PROP_VAL, TLS_TRUSTS_STORE_PASSWD_PROP_KEY, TLS_TRUSTS_STORE_PASSWD_PROP_VAL, TLS_TRUSTS_STORE_PROP_KEY, TLS_TRUSTS_STORE_PROP_VAL, TLS_USE_PROP_KEY, TLS_USE_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, maxQueueSize, MINUTE, OUTGOING_FILTERS_PROP_KEY, OUTGOING_FILTERS_PROP_VAL, SECOND
 
Fields inherited from class tigase.server.BasicComponent
admins, SCRIPTS_DIR_PROP_DEF, SCRIPTS_DIR_PROP_KEY, vHostManager
 
Fields inherited from interface tigase.conf.Configurable
ADMINS_PROP_KEY, AUTH_REPO_CLASS_PROP_KEY, AUTH_REPO_PARAMS_NODE, AUTH_REPO_URL_PROP_KEY, 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_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_S2S_NAME, DEF_SM_NAME, DEF_SRECV_NAME, DEF_SSEND_NAME, DEF_STATS_NAME, DEF_VHOST_MAN_NAME, DERBY_REPO_CLASS_PROP_VAL, DERBY_REPO_URL_PROP_VAL, DRUPAL_REPO_CLASS_PROP_VAL, DRUPAL_REPO_URL_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_VIRT_HOSTS, HOSTNAMES_PROP_KEY, LIBRESOURCE_REPO_CLASS_PROP_VAL, LIBRESOURCE_REPO_URL_PROP_VAL, 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_POOL_PROP_KEY, SHARED_USER_REPO_PROP_KEY, SM_CLUS_COMP_CLASS_NAME, SM_COMP_CLASS_NAME, SRECV_COMP_CLASS_NAME, SSEND_COMP_CLASS_NAME, 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_REPO_CLASS_PROP_KEY, USER_REPO_PARAMS_NODE, USER_REPO_POOL_SIZE, USER_REPO_POOL_SIZE_PROP_KEY, USER_REPO_URL_PROP_KEY, VHOST_MAN_CLASS_NAME, XML_REPO_CLASS_PROP_VAL, XML_REPO_URL_PROP_VAL
 
Fields inherited from interface tigase.disco.XMPPService
CMD_FEATURES, DEF_FEATURES, INFO_XMLNS, ITEMS_XMLNS
 
Constructor Summary
BoshConnectionManager()
           
 
Method Summary
 boolean addOutStreamClosed(Packet packet, BoshSession bs)
          Method description
 boolean addOutStreamOpen(Packet packet, BoshSession bs)
           
 void cancelTask(TimerTask tt)
          Method description
protected  tigase.xmpp.JID changeDataReceiver(Packet packet, tigase.xmpp.JID newAddress, String command_sessionId, XMPPIOService<Object> serv)
           
protected  BoshSession getBoshSession(tigase.xmpp.JID jid)
           
 Map<String,Object> getDefaults(Map<String,Object> params)
          Method description
protected  int[] getDefPlainPorts()
           
protected  int[] getDefSSLPorts()
           
 String getDiscoCategoryType()
          Method description
 String getDiscoDescription()
          Method description
protected  long getMaxInactiveTime()
          Method getMaxInactiveTime returns max keep-alive time for inactive connection.
protected  BoshIOService getXMPPIOServiceInstance()
           
protected  ReceiverTimeoutHandler newStartedHandler()
           
protected  void processCommand(Packet packet)
           
 Queue<Packet> processSocketData(XMPPIOService<Object> srv)
          Method description
 TimerTask scheduleTask(BoshSession bs, long delay)
          Method description
 void serviceStarted(BoshIOService service)
          Method description
 void serviceStopped(BoshIOService service)
          Method description
 void setProperties(Map<String,Object> props)
          Method description
protected  boolean writePacketToSocket(Packet packet)
           
 void writeRawData(BoshIOService ios, String data)
          Method description
 void xmppStreamClosed(BoshIOService serv)
          Method description
 String xmppStreamOpened(BoshIOService serv, Map<String,String> attribs)
          Method description
 
Methods inherited from class tigase.server.xmppclient.ClientConnectionManager
getMaxQueueSize, hashCodeForPacket, newStoppedHandler, processingThreads, processPacket, serviceStopped, start, stop, xmppStreamClosed, xmppStreamOpened
 
Methods inherited from class tigase.server.ConnectionManager
addWaitingTask, countIOServices, doForAllServices, getParamsForPort, getServiceId, getServiceId, getStatistics, getUniqueId, getXMPPIOService, getXMPPIOService, initializationCompleted, isHighThroughput, packetsReady, release, serviceStarted, setName, writePacketsToSocket, writePacketToSocket, writePacketToSocket, writeRawData
 
Methods inherited from class tigase.server.AbstractMessageReceiver
addOutPacket, addOutPacketNB, addOutPackets, addOutPacketWithTimeout, addPacket, addPacketNB, addPackets, addRegexRouting, addTimerTask, addTimerTask, clearRegexRoutings, everyHour, everyMinute, everySecond, getRegexRoutings, isInRegexRoutings, newPacketId, processPacket, removeRegexRouting, setMaxQueueSize, setParent
 
Methods inherited from class tigase.server.BasicComponent
addComponentDomain, getComponentId, getDefHostName, getDiscoFeatures, getDiscoFeatures, getDiscoInfo, getDiscoInfo, getDiscoItems, getDiscoItems, getName, getVHostItem, handlesLocalDomains, handlesNameSubdomains, handlesNonLocalDomains, initBindings, isAdmin, isLocalDomain, isLocalDomainOrComponent, processScriptCommand, removeComponentDomain, removeServiceDiscoveryItem, setVHostManager, updateServiceDiscoveryItem, updateServiceDiscoveryItem, updateServiceDiscoveryItem
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface tigase.server.MessageReceiver
getDefHostName
 
Methods inherited from interface tigase.server.ServerComponent
getComponentId, getName
 

Constructor Detail

BoshConnectionManager

public BoshConnectionManager()
Method Detail

addOutStreamClosed

public boolean addOutStreamClosed(Packet packet,
                                  BoshSession bs)
Method description

Specified by:
addOutStreamClosed in interface BoshSessionTaskHandler
Parameters:
packet -
bs -
Returns:

addOutStreamOpen

public boolean addOutStreamOpen(Packet packet,
                                BoshSession bs)
Specified by:
addOutStreamOpen in interface BoshSessionTaskHandler
Parameters:
packet -
bs -
Returns:

cancelTask

public void cancelTask(TimerTask tt)
Method description

Specified by:
cancelTask in interface BoshSessionTaskHandler
Parameters:
tt -

getDefaults

public Map<String,Object> getDefaults(Map<String,Object> params)
Method description

Specified by:
getDefaults in interface Configurable
Overrides:
getDefaults in class ClientConnectionManager
Parameters:
params -
Returns:

getDiscoCategoryType

public String getDiscoCategoryType()
Method description

Overrides:
getDiscoCategoryType in class ClientConnectionManager
Returns:

getDiscoDescription

public String getDiscoDescription()
Method description

Overrides:
getDiscoDescription in class ClientConnectionManager
Returns:

processSocketData

public Queue<Packet> processSocketData(XMPPIOService<Object> srv)
Method description

Overrides:
processSocketData in class ClientConnectionManager
Parameters:
srv -
Returns:

scheduleTask

public TimerTask scheduleTask(BoshSession bs,
                              long delay)
Method description

Specified by:
scheduleTask in interface BoshSessionTaskHandler
Parameters:
bs -
delay -
Returns:

serviceStarted

public void serviceStarted(BoshIOService service)
Method description

Parameters:
service -

serviceStopped

public void serviceStopped(BoshIOService service)
Method description

Parameters:
service -

setProperties

public void setProperties(Map<String,Object> props)
Method description

Specified by:
setProperties in interface Configurable
Overrides:
setProperties in class ClientConnectionManager
Parameters:
props -

writeRawData

public void writeRawData(BoshIOService ios,
                         String data)
Method description

Specified by:
writeRawData in interface BoshSessionTaskHandler
Parameters:
ios -
data -

xmppStreamClosed

public void xmppStreamClosed(BoshIOService serv)
Method description

Parameters:
serv -

xmppStreamOpened

public String xmppStreamOpened(BoshIOService serv,
                               Map<String,String> attribs)
Method description

Parameters:
serv -
attribs -
Returns:

changeDataReceiver

protected tigase.xmpp.JID changeDataReceiver(Packet packet,
                                             tigase.xmpp.JID newAddress,
                                             String command_sessionId,
                                             XMPPIOService<Object> serv)
Overrides:
changeDataReceiver in class ClientConnectionManager

getBoshSession

protected BoshSession getBoshSession(tigase.xmpp.JID jid)

getDefPlainPorts

protected int[] getDefPlainPorts()
Overrides:
getDefPlainPorts in class ClientConnectionManager

getDefSSLPorts

protected int[] getDefSSLPorts()
Overrides:
getDefSSLPorts in class ClientConnectionManager

getMaxInactiveTime

protected long getMaxInactiveTime()
Method getMaxInactiveTime returns max keep-alive time for inactive connection. we shoulnd not really close external component connection at all, so let's say something like: 1000 days...

Overrides:
getMaxInactiveTime in class ClientConnectionManager
Returns:
a long value

getXMPPIOServiceInstance

protected BoshIOService getXMPPIOServiceInstance()
Overrides:
getXMPPIOServiceInstance in class ClientConnectionManager

newStartedHandler

protected ReceiverTimeoutHandler newStartedHandler()
Overrides:
newStartedHandler in class ClientConnectionManager

processCommand

protected void processCommand(Packet packet)
Overrides:
processCommand in class ClientConnectionManager

writePacketToSocket

protected boolean writePacketToSocket(Packet packet)
Overrides:
writePacketToSocket in class ConnectionManager<XMPPIOService<Object>>
Returns:


Copyright © 2001-2006 Tigase Developers Team. All rights Reserved.