public class StreamManagementIOProcessor extends Object implements XMPPIOProcessor
Modifier and Type | Class and Description |
---|---|
static class |
StreamManagementIOProcessor.OutQueue
OutQueue class implements queue of outgoing packets waiting for ack
with implementation of removing acked elements when id of acked packet
is passed
|
Constructor and Description |
---|
StreamManagementIOProcessor() |
Modifier and Type | Method and Description |
---|---|
String |
getId()
Returns identifier of processor
|
static boolean |
isEnabled(XMPPIOService service)
Method returns true if XMPPIOService has enabled SM.
|
void |
packetsSent(XMPPIOService service)
Method is called when all waiting data was written to socket.
|
void |
processCommand(XMPPIOService service,
Packet pc)
Process command execution which may be sent from other component and
should be processed by processor
|
boolean |
processIncoming(XMPPIOService service,
Packet packet)
Process packets read from socket as they are sent to SessionManager.
|
boolean |
processOutgoing(XMPPIOService service,
Packet packet)
Process outgoing packets as they are added to XMPPIOService outgoing
packets queue.
|
boolean |
serviceStopped(XMPPIOService service,
boolean streamClosed)
Method called when XMPPIOService is closed.
|
void |
setConnectionManager(ConnectionManager connectionManager)
Sets connection manager instance for which this XMPPIOProcessor is used
|
void |
setProperties(Map<String,Object> props)
Method used for setting properties
|
tigase.xml.Element[] |
supStreamFeatures(XMPPIOService service)
Returns array of features added by this processor
|
public static final String XMLNS
public static boolean isEnabled(XMPPIOService service)
service
- public String getId()
XMPPIOProcessor
getId
in interface XMPPIOProcessor
public void setConnectionManager(ConnectionManager connectionManager)
XMPPIOProcessor
setConnectionManager
in interface XMPPIOProcessor
public tigase.xml.Element[] supStreamFeatures(XMPPIOService service)
XMPPIOProcessor
supStreamFeatures
in interface XMPPIOProcessor
public boolean processIncoming(XMPPIOService service, Packet packet)
XMPPIOProcessor
processIncoming
in interface XMPPIOProcessor
public boolean processOutgoing(XMPPIOService service, Packet packet)
XMPPIOProcessor
processOutgoing
in interface XMPPIOProcessor
public void packetsSent(XMPPIOService service) throws IOException
XMPPIOProcessor
packetsSent
in interface XMPPIOProcessor
IOException
public void processCommand(XMPPIOService service, Packet pc)
XMPPIOProcessor
processCommand
in interface XMPPIOProcessor
public boolean serviceStopped(XMPPIOService service, boolean streamClosed)
XMPPIOProcessor
serviceStopped
in interface XMPPIOProcessor
public void setProperties(Map<String,Object> props)
XMPPIOProcessor
setProperties
in interface XMPPIOProcessor
Copyright © 2014 "Tigase, Inc.". All rights reserved.