|
||||||||||
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.xmppclient.ClientConnectionManager
public class ClientConnectionManager
Class ClientConnectionManager Created: Tue Nov 22 07:07:11 2005
Field Summary | |
---|---|
protected RoutingsContainer |
routings
|
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 | |
---|---|
ClientConnectionManager()
|
Method Summary | |
---|---|
protected tigase.xmpp.JID |
changeDataReceiver(Packet packet,
tigase.xmpp.JID newAddress,
String command_sessionId,
XMPPIOService<Object> serv)
|
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 Integer |
getMaxQueueSize(int def)
|
protected XMPPIOService<Object> |
getXMPPIOServiceInstance()
|
int |
hashCodeForPacket(Packet packet)
This method can be overwritten in extending classes to get a different packets distribution to different threads. |
protected ReceiverTimeoutHandler |
newStartedHandler()
|
protected ReceiverTimeoutHandler |
newStoppedHandler()
|
protected void |
processCommand(Packet packet)
|
int |
processingThreads()
Method description |
void |
processPacket(Packet packet)
Method description |
Queue<Packet> |
processSocketData(XMPPIOService<Object> serv)
Method description |
boolean |
serviceStopped(XMPPIOService<Object> service)
Method description |
void |
setProperties(Map<String,Object> props)
Method description |
void |
start()
Method description |
void |
stop()
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, getParamsForPort, getServiceId, getServiceId, getStatistics, getUniqueId, getXMPPIOService, getXMPPIOService, initializationCompleted, isHighThroughput, packetsReady, release, serviceStarted, setName, 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, getRegexRoutings, isInRegexRoutings, newPacketId, processPacket, removeRegexRouting, setMaxQueueSize, setParent |
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 |
Field Detail |
---|
protected RoutingsContainer routings
Constructor Detail |
---|
public ClientConnectionManager()
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 int hashCodeForPacket(Packet packet)
hashCodeForPacket
in class AbstractMessageReceiver
packet
-
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 int processingThreads()
processingThreads
in class AbstractMessageReceiver
public boolean serviceStopped(XMPPIOService<Object> service)
serviceStopped
in interface IOServiceListener<XMPPIOService<Object>>
serviceStopped
in class ConnectionManager<XMPPIOService<Object>>
service
-
public void setProperties(Map<String,Object> props)
setProperties
in interface Configurable
setProperties
in class ConnectionManager<XMPPIOService<Object>>
props
- public void start()
start
in interface MessageReceiver
start
in class ConnectionManager<XMPPIOService<Object>>
public void stop()
stop
in class AbstractMessageReceiver
public void xmppStreamClosed(XMPPIOService<Object> serv)
serv
- public String xmppStreamOpened(XMPPIOService<Object> serv, Map<String,String> attribs)
serv
- attribs
-
protected tigase.xmpp.JID changeDataReceiver(Packet packet, tigase.xmpp.JID newAddress, String command_sessionId, XMPPIOService<Object> serv)
protected int[] getDefPlainPorts()
getDefPlainPorts
in class ConnectionManager<XMPPIOService<Object>>
protected int[] getDefSSLPorts()
getDefSSLPorts
in class ConnectionManager<XMPPIOService<Object>>
protected long getMaxInactiveTime()
getMaxInactiveTime
returns max keep-alive time
for inactive connection. Let's assume user should send something
at least once every 24 hours....
getMaxInactiveTime
in class ConnectionManager<XMPPIOService<Object>>
long
valueprotected Integer getMaxQueueSize(int def)
getMaxQueueSize
in class AbstractMessageReceiver
protected XMPPIOService<Object> getXMPPIOServiceInstance()
getXMPPIOServiceInstance
in class ConnectionManager<XMPPIOService<Object>>
protected ReceiverTimeoutHandler newStartedHandler()
protected ReceiverTimeoutHandler newStoppedHandler()
protected void processCommand(Packet packet)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |