- All Implemented Interfaces:
@Bean(name="urn:xmpp:sm:3", parent=ClientConnectionManager.class, active=true) public class StreamManagementIOProcessor extends Object implements XMPPIOProcessor
Class implements XEP-0198 Stream Management
Nested Class SummaryModifier and TypeClassDescription
static classCounter class implements proper counter with overflow from 2^32-1 to 0
static classOutQueue class implements queue of outgoing packets waiting for ack with implementation of removing acked elements when id of acked packet is passed
Method SummaryModifier and TypeMethodDescription
getId()Returns identifier of processor
voidReturns statistics generated by this processor
static booleanMethod returns true if XMPPIOService has enabled SM.
voidMethod is called when all waiting data was written to socket.
voidProcess command execution which may be sent from other component and should be processed by processor
booleanProcess packets read from socket as they are sent to SessionManager.
booleanProcess outgoing packets as they are added to XMPPIOService outgoing packets queue.
booleanMethod called when XMPPIOService is closed.
protected booleanOverride this method to define a custom behaviour for request ack.
voidMethod called when XMPP stream error is about to be sent
ElementReturns array of features added by this processor
isEnabledpublic static boolean isEnabled
(XMPPIOService service)Method returns true if XMPPIOService has enabled SM.
getIdpublic String getId()Returns identifier of processor
supStreamFeaturesReturns array of features added by this processor
processIncomingProcess packets read from socket as they are sent to SessionManager.
processOutgoingProcess outgoing packets as they are added to XMPPIOService outgoing packets queue.
packetsSentMethod is called when all waiting data was written to socket.
processCommandProcess command execution which may be sent from other component and should be processed by processor
serviceStoppedpublic boolean serviceStopped
(XMPPIOService service, boolean streamClosed)Method called when XMPPIOService is closed.
getStatisticspublic void getStatistics
(StatisticsList list)Returns statistics generated by this processor
streamErrorMethod called when XMPP stream error is about to be sent
shouldRequestAckprotected boolean shouldRequestAck
(XMPPIOService service, StreamManagementIOProcessor.OutQueue outQueue)Override this method to define a custom behaviour for request ack. The default implementation will request an ack if there are more than
ack_request_countpackets waiting since last request for ack and last ack request was not sent in last X ms.
newCounterprotected StreamManagementIOProcessor.Counter newCounter()
newOutQueueprotected StreamManagementIOProcessor.OutQueue newOutQueue()
isStanzaprotected boolean isStanza