|
||||||||||
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<XMPPIOService<Object>>
tigase.server.xmppserver.ServerConnectionManager
public class ServerConnectionManager
Class ServerConnectionManager Created: Tue Nov 22 07:07:11 2005
Field Summary | |
---|---|
static String |
MAX_PACKET_WAITING_TIME_PROP_KEY
Field description |
static long |
MAX_PACKET_WAITING_TIME_PROP_VAL
Field description |
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 | |
---|---|
ServerConnectionManager()
|
Method Summary | |
---|---|
Map<String,Object> |
getDefaults(Map<String,Object> params)
Method description |
protected int[] |
getDefPlainPorts()
|
String |
getDiscoCategoryType()
Method description |
String |
getDiscoDescription()
Method description |
protected String |
getLocalDBKey(CID cid,
String key,
String forkey_sessionId,
String asking_sessionId)
|
protected long |
getMaxInactiveTime()
Method getMaxInactiveTime returns max keep-alive time
for inactive connection. |
protected ServerConnections |
getServerConnections(CID cid)
|
void |
getStatistics(StatisticsList list)
Method description |
protected XMPPIOService<Object> |
getXMPPIOServiceInstance()
|
boolean |
handlesNonLocalDomains()
Method description |
int |
hashCodeForPacket(Packet packet)
Method description |
protected boolean |
isHighThroughput()
|
boolean |
isIncomingValid(String session_id)
Method description |
void |
processDialback(Packet packet,
XMPPIOService<Object> serv)
Method description |
void |
processPacket(Packet packet)
Method description |
Queue<Packet> |
processSocketData(XMPPIOService<Object> serv)
Method description |
protected ServerConnections |
removeServerConnections(CID cid)
|
boolean |
sendToIncoming(String session_id,
Packet packet)
Method description |
protected void |
sendVerifyResult(String from,
String to,
String forkey_sessionId,
boolean valid,
ServerConnections serv_conns,
String asking_sessionId)
|
void |
serviceStarted(XMPPIOService<Object> serv)
Method description |
boolean |
serviceStopped(XMPPIOService<Object> serv)
Method description |
void |
setProperties(Map<String,Object> props)
Method description |
void |
validateIncoming(String session_id,
boolean valid)
Method description |
void |
xmppStreamClosed(XMPPIOService<Object> serv)
Method description |
String |
xmppStreamOpened(XMPPIOService<Object> serv,
Map<String,String> attribs)
Method description |
Methods inherited from class tigase.server.ConnectionManager |
---|
addWaitingTask, countIOServices, doForAllServices, getDefSSLPorts, getParamsForPort, getServiceId, getServiceId, getUniqueId, getXMPPIOService, getXMPPIOService, initializationCompleted, packetsReady, release, setName, start, writePacketsToSocket, writePacketToSocket, writePacketToSocket, writePacketToSocket, writeRawData |
Methods inherited from class tigase.server.AbstractMessageReceiver |
---|
addOutPacket, addOutPacketNB, addOutPackets, addOutPacketWithTimeout, addPacket, addPacketNB, addPackets, addRegexRouting, addTimerTask, addTimerTask, clearRegexRoutings, everyHour, everyMinute, everySecond, getMaxQueueSize, getRegexRoutings, 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.server.xmppserver.ConnectionHandlerIfc |
---|
writePacketsToSocket, writePacketToSocket |
Methods inherited from interface tigase.server.MessageReceiver |
---|
getDefHostName |
Methods inherited from interface tigase.server.ServerComponent |
---|
getComponentId, getName |
Field Detail |
---|
public static final String MAX_PACKET_WAITING_TIME_PROP_KEY
public static final long MAX_PACKET_WAITING_TIME_PROP_VAL
Constructor Detail |
---|
public ServerConnectionManager()
Method Detail |
---|
public Map<String,Object> getDefaults(Map<String,Object> params)
getDefaults
in interface Configurable
getDefaults
in class ConnectionManager<XMPPIOService<Object>>
params
-
public String getDiscoCategoryType()
getDiscoCategoryType
in class BasicComponent
public String getDiscoDescription()
getDiscoDescription
in class BasicComponent
public void getStatistics(StatisticsList list)
getStatistics
in interface StatisticsContainer
getStatistics
in class ConnectionManager<XMPPIOService<Object>>
list
- public boolean handlesNonLocalDomains()
handlesNonLocalDomains
in interface VHostListener
handlesNonLocalDomains
in class BasicComponent
public int hashCodeForPacket(Packet packet)
hashCodeForPacket
in class AbstractMessageReceiver
packet
-
public boolean isIncomingValid(String session_id)
session_id
-
public void processDialback(Packet packet, XMPPIOService<Object> serv)
packet
- serv
- public void processPacket(Packet packet)
processPacket
in class ConnectionManager<XMPPIOService<Object>>
packet
- public Queue<Packet> processSocketData(XMPPIOService<Object> serv)
processSocketData
in class ConnectionManager<XMPPIOService<Object>>
serv
-
public boolean sendToIncoming(String session_id, Packet packet)
session_id
- packet
-
public void serviceStarted(XMPPIOService<Object> serv)
serviceStarted
in class ConnectionManager<XMPPIOService<Object>>
serv
- public boolean serviceStopped(XMPPIOService<Object> serv)
serviceStopped
in interface IOServiceListener<XMPPIOService<Object>>
serviceStopped
in class ConnectionManager<XMPPIOService<Object>>
serv
-
public void setProperties(Map<String,Object> props)
setProperties
in interface Configurable
setProperties
in class ConnectionManager<XMPPIOService<Object>>
props
- public void validateIncoming(String session_id, boolean valid)
session_id
- valid
- public void xmppStreamClosed(XMPPIOService<Object> serv)
xmppStreamClosed
in interface XMPPIOServiceListener<XMPPIOService<Object>>
serv
- public String xmppStreamOpened(XMPPIOService<Object> serv, Map<String,String> attribs)
xmppStreamOpened
in interface XMPPIOServiceListener<XMPPIOService<Object>>
serv
- attribs
-
protected int[] getDefPlainPorts()
getDefPlainPorts
in class ConnectionManager<XMPPIOService<Object>>
protected String getLocalDBKey(CID cid, String key, String forkey_sessionId, String asking_sessionId)
protected long getMaxInactiveTime()
getMaxInactiveTime
returns max keep-alive time
for inactive connection. Let's assume s2s should send something
at least once every 15 minutes....
getMaxInactiveTime
in class ConnectionManager<XMPPIOService<Object>>
long
valueprotected ServerConnections getServerConnections(CID cid)
protected XMPPIOService<Object> getXMPPIOServiceInstance()
getXMPPIOServiceInstance
in class ConnectionManager<XMPPIOService<Object>>
protected boolean isHighThroughput()
isHighThroughput
in class ConnectionManager<XMPPIOService<Object>>
protected ServerConnections removeServerConnections(CID cid)
protected void sendVerifyResult(String from, String to, String forkey_sessionId, boolean valid, ServerConnections serv_conns, String asking_sessionId)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |