|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objecttigase.server.BasicComponent
tigase.server.AbstractMessageReceiver
tigase.server.ConnectionManager<IO>
IO
- public abstract class ConnectionManager<IO extends XMPPIOService>
Describe class ConnectionManager here. Created: Sun Jan 22 22:52:58 2006
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.disco.XMPPService |
---|
CMD_FEATURES, DEF_FEATURES, INFO_XMLNS, ITEMS_XMLNS |
Constructor Summary | |
---|---|
ConnectionManager()
|
Method Summary | |
---|---|
protected void |
addWaitingTask(Map<String,Object> conn)
|
protected int |
countIOServices()
Returns number of active network connections (IOServices). |
protected void |
doForAllServices(ServiceChecker checker)
Perform a given action defined by ServiceChecker for all active IOService objects (active network connections). |
Map<String,Object> |
getDefaults(Map<String,Object> params)
Method description |
protected int[] |
getDefPlainPorts()
|
protected int[] |
getDefSSLPorts()
|
protected abstract long |
getMaxInactiveTime()
|
protected Map<String,Object> |
getParamsForPort(int port)
|
protected String |
getServiceId(tigase.xmpp.JID jid)
|
protected String |
getServiceId(Packet packet)
|
void |
getStatistics(StatisticsList list)
Generates the component statistics. |
protected String |
getUniqueId(IO serv)
|
protected IO |
getXMPPIOService(Packet p)
|
protected IO |
getXMPPIOService(String serviceId)
|
protected abstract IO |
getXMPPIOServiceInstance()
|
void |
initializationCompleted()
Method description |
protected boolean |
isHighThroughput()
|
void |
packetsReady(IO serv)
Method description |
void |
processPacket(Packet packet)
Method description |
abstract Queue<Packet> |
processSocketData(IO serv)
Method description |
void |
release()
Method description |
void |
serviceStarted(IO service)
Method description |
boolean |
serviceStopped(IO service)
|
void |
setName(String name)
Method description |
void |
setProperties(Map<String,Object> props)
Method description |
void |
start()
Method description |
void |
writePacketsToSocket(IO serv,
Queue<Packet> packets)
Method description |
boolean |
writePacketToSocket(IO ios,
Packet p)
Method description |
protected boolean |
writePacketToSocket(Packet p)
|
protected boolean |
writePacketToSocket(Packet p,
String serviceId)
|
protected void |
writeRawData(IO ios,
String data)
|
Methods inherited from class tigase.server.AbstractMessageReceiver |
---|
addOutPacket, addOutPacketNB, addOutPackets, addOutPacketWithTimeout, addPacket, addPacketNB, addPackets, addRegexRouting, addTimerTask, addTimerTask, clearRegexRoutings, everyHour, everyMinute, everySecond, getMaxQueueSize, getRegexRoutings, hashCodeForPacket, isInRegexRoutings, newPacketId, processingThreads, processPacket, removeRegexRouting, setMaxQueueSize, setParent, stop |
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.server.MessageReceiver |
---|
getDefHostName |
Methods inherited from interface tigase.server.ServerComponent |
---|
getComponentId, getName |
Field Detail |
---|
public static final String NET_BUFFER_ST_PROP_KEY
public static final String NET_BUFFER_HT_PROP_KEY
protected static final String PORT_KEY
protected static final String PROP_KEY
protected static final String PORTS_PROP_KEY
protected static final String PORT_TYPE_PROP_KEY
protected static final String PORT_SOCKET_PROP_KEY
protected static final String PORT_IFC_PROP_KEY
protected static final String PORT_CLASS_PROP_KEY
protected static final String PORT_REMOTE_HOST_PROP_KEY
protected static final String PORT_REMOTE_HOST_PROP_VAL
protected static final String TLS_PROP_KEY
protected static final String TLS_USE_PROP_KEY
protected static final boolean TLS_USE_PROP_VAL
protected static final String TLS_REQUIRED_PROP_KEY
protected static final boolean TLS_REQUIRED_PROP_VAL
protected static final String TLS_KEYS_STORE_PROP_KEY
protected static final String TLS_KEYS_STORE_PROP_VAL
protected static final String TLS_DEF_CERT_PROP_KEY
protected static final String TLS_DEF_CERT_PROP_VAL
protected static final String TLS_KEYS_STORE_PASSWD_PROP_KEY
protected static final String TLS_KEYS_STORE_PASSWD_PROP_VAL
protected static final String TLS_TRUSTS_STORE_PASSWD_PROP_KEY
protected static final String TLS_TRUSTS_STORE_PASSWD_PROP_VAL
protected static final String TLS_TRUSTS_STORE_PROP_KEY
protected static final String TLS_TRUSTS_STORE_PROP_VAL
protected static final String TLS_CONTAINER_CLASS_PROP_KEY
protected static final String TLS_CONTAINER_CLASS_PROP_VAL
protected static final String TLS_SERVER_CERTS_DIR_PROP_KEY
protected static final String TLS_SERVER_CERTS_DIR_PROP_VAL
protected static final String TLS_TRUSTED_CERTS_DIR_PROP_KEY
protected static final String TLS_TRUSTED_CERTS_DIR_PROP_VAL
protected static final String TLS_ALLOW_SELF_SIGNED_CERTS_PROP_KEY
protected static final String TLS_ALLOW_SELF_SIGNED_CERTS_PROP_VAL
protected static final String TLS_ALLOW_INVALID_CERTS_PROP_KEY
protected static final String TLS_ALLOW_INVALID_CERTS_PROP_VAL
protected static final String MAX_RECONNECTS_PROP_KEY
protected static final String NET_BUFFER_PROP_KEY
protected static final int NET_BUFFER_ST_PROP_VAL
protected static final int NET_BUFFER_HT_PROP_VAL
public static final String PORT_LOCAL_HOST_PROP_KEY
public String[] PORT_IFC_PROP_VAL
protected int net_buffer
protected long connectionDelay
Constructor Detail |
---|
public ConnectionManager()
Method Detail |
---|
public abstract Queue<Packet> processSocketData(IO serv)
serv
-
protected abstract long getMaxInactiveTime()
protected abstract IO getXMPPIOServiceInstance()
public Map<String,Object> getDefaults(Map<String,Object> params)
getDefaults
in interface Configurable
getDefaults
in class AbstractMessageReceiver
params
-
public void getStatistics(StatisticsList list)
getStatistics
in interface StatisticsContainer
getStatistics
in class AbstractMessageReceiver
list
- is a collection to put the component statistics in.public void initializationCompleted()
initializationCompleted
in interface ServerComponent
initializationCompleted
in class BasicComponent
public void packetsReady(IO serv) throws IOException
packetsReady
in interface IOServiceListener<IO extends XMPPIOService>
serv
-
IOException
public void processPacket(Packet packet)
processPacket
in class AbstractMessageReceiver
packet
- public void release()
release
in interface ServerComponent
release
in class AbstractMessageReceiver
@TODO(note="Do something if service with the same unique ID is already started, possibly kill the old one...") public void serviceStarted(IO service)
service
- public boolean serviceStopped(IO service)
serviceStopped
in interface IOServiceListener<IO extends XMPPIOService>
service
-
public void setName(String name)
setName
in interface ServerComponent
setName
in class AbstractMessageReceiver
name
- public void setProperties(Map<String,Object> props)
setProperties
in interface Configurable
setProperties
in class AbstractMessageReceiver
props
- public void start()
start
in interface MessageReceiver
start
in class AbstractMessageReceiver
public boolean writePacketToSocket(IO ios, Packet p)
ios
- p
-
public void writePacketsToSocket(IO serv, Queue<Packet> packets)
serv
- packets
- protected void addWaitingTask(Map<String,Object> conn)
protected int countIOServices()
protected void doForAllServices(ServiceChecker checker)
checker
- is a ServiceChecker
instance defining an action
to perform for all IOService objects.protected int[] getDefPlainPorts()
protected int[] getDefSSLPorts()
protected Map<String,Object> getParamsForPort(int port)
protected String getServiceId(Packet packet)
protected String getServiceId(tigase.xmpp.JID jid)
protected String getUniqueId(IO serv)
protected IO getXMPPIOService(String serviceId)
protected IO getXMPPIOService(Packet p)
protected boolean isHighThroughput()
protected boolean writePacketToSocket(Packet p)
p
-
protected boolean writePacketToSocket(Packet p, String serviceId)
protected void writeRawData(IO ios, String data)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |