Package tigase.server.xmppclient
Class RegistrationThrottlingProcessor
java.lang.Object
tigase.server.xmppclient.RegistrationThrottlingProcessor
- All Implemented Interfaces:
XMPPIOProcessor
@Bean(name="registration-throttling-processor",
active=true)
public class RegistrationThrottlingProcessor
extends Object
implements XMPPIOProcessor
Created by andrzej on 16.11.2016.
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptiongetId()
Returns identifier of processorvoid
getStatistics
(StatisticsList list) Returns statistics generated by this processorvoid
packetsSent
(XMPPIOService service) Method is called when all waiting data was written to socket.void
processCommand
(XMPPIOService service, Packet packet) Process command execution which may be sent from other component and should be processed by processorboolean
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
streamError
(XMPPIOService service, StreamError streamError) Method called when XMPP stream error is about to be sentElement[]
supStreamFeatures
(XMPPIOService service) Returns array of features added by this processor
-
Field Details
-
ID
- See Also:
-
-
Constructor Details
-
RegistrationThrottlingProcessor
public RegistrationThrottlingProcessor()
-
-
Method Details
-
getId
Description copied from interface:XMPPIOProcessor
Returns identifier of processor- Specified by:
getId
in interfaceXMPPIOProcessor
-
getStatistics
Description copied from interface:XMPPIOProcessor
Returns statistics generated by this processor- Specified by:
getStatistics
in interfaceXMPPIOProcessor
-
supStreamFeatures
Description copied from interface:XMPPIOProcessor
Returns array of features added by this processor- Specified by:
supStreamFeatures
in interfaceXMPPIOProcessor
-
processIncoming
Description copied from interface:XMPPIOProcessor
Process packets read from socket as they are sent to SessionManager.- Specified by:
processIncoming
in interfaceXMPPIOProcessor
- Returns:
- true if packet should not be forwarded
-
processOutgoing
Description copied from interface:XMPPIOProcessor
Process outgoing packets as they are added to XMPPIOService outgoing packets queue.- Specified by:
processOutgoing
in interfaceXMPPIOProcessor
- Returns:
- true if packet should be removed
-
packetsSent
Description copied from interface:XMPPIOProcessor
Method is called when all waiting data was written to socket.- Specified by:
packetsSent
in interfaceXMPPIOProcessor
- Throws:
IOException
-
processCommand
Description copied from interface:XMPPIOProcessor
Process command execution which may be sent from other component and should be processed by processor- Specified by:
processCommand
in interfaceXMPPIOProcessor
-
serviceStopped
Description copied from interface:XMPPIOProcessor
Method called when XMPPIOService is closed.- Specified by:
serviceStopped
in interfaceXMPPIOProcessor
- Returns:
- true if connecton manager should not be notified about stopping of this service
-
streamError
Description copied from interface:XMPPIOProcessor
Method called when XMPP stream error is about to be sent- Specified by:
streamError
in interfaceXMPPIOProcessor
-