|
||||||||||
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
tigase.server.bosh.BoshConnectionManager
public class BoshConnectionManager
Describe class BoshConnectionManager here. Created: Sat Jun 2 12:24:29 2007
Field Summary |
---|
Fields inherited from class tigase.server.xmppclient.ClientConnectionManager |
---|
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 | |
---|---|
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 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 |
---|
public BoshConnectionManager()
Method Detail |
---|
public boolean addOutStreamClosed(Packet packet, BoshSession bs)
addOutStreamClosed
in interface BoshSessionTaskHandler
packet
- bs
-
public boolean addOutStreamOpen(Packet packet, BoshSession bs)
addOutStreamOpen
in interface BoshSessionTaskHandler
packet
- bs
-
public void cancelTask(TimerTask tt)
cancelTask
in interface BoshSessionTaskHandler
tt
- public Map<String,Object> getDefaults(Map<String,Object> params)
getDefaults
in interface Configurable
getDefaults
in class ClientConnectionManager
params
-
public String getDiscoCategoryType()
getDiscoCategoryType
in class ClientConnectionManager
public String getDiscoDescription()
getDiscoDescription
in class ClientConnectionManager
public Queue<Packet> processSocketData(XMPPIOService<Object> srv)
processSocketData
in class ClientConnectionManager
srv
-
public TimerTask scheduleTask(BoshSession bs, long delay)
scheduleTask
in interface BoshSessionTaskHandler
bs
- delay
-
public void serviceStarted(BoshIOService service)
service
- public void serviceStopped(BoshIOService service)
service
- public void setProperties(Map<String,Object> props)
setProperties
in interface Configurable
setProperties
in class ClientConnectionManager
props
- public void writeRawData(BoshIOService ios, String data)
writeRawData
in interface BoshSessionTaskHandler
ios
- data
- public void xmppStreamClosed(BoshIOService serv)
serv
- public String xmppStreamOpened(BoshIOService serv, Map<String,String> attribs)
serv
- attribs
-
protected tigase.xmpp.JID changeDataReceiver(Packet packet, tigase.xmpp.JID newAddress, String command_sessionId, XMPPIOService<Object> serv)
changeDataReceiver
in class ClientConnectionManager
protected BoshSession getBoshSession(tigase.xmpp.JID jid)
protected int[] getDefPlainPorts()
getDefPlainPorts
in class ClientConnectionManager
protected int[] getDefSSLPorts()
getDefSSLPorts
in class ClientConnectionManager
protected long getMaxInactiveTime()
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...
getMaxInactiveTime
in class ClientConnectionManager
long
valueprotected BoshIOService getXMPPIOServiceInstance()
getXMPPIOServiceInstance
in class ClientConnectionManager
protected ReceiverTimeoutHandler newStartedHandler()
newStartedHandler
in class ClientConnectionManager
protected void processCommand(Packet packet)
processCommand
in class ClientConnectionManager
protected boolean writePacketToSocket(Packet packet)
writePacketToSocket
in class ConnectionManager<XMPPIOService<Object>>
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |