Package tigase.server.xmppclient
Class StreamManagementIOProcessor.OutQueue
java.lang.Object
tigase.server.xmppclient.StreamManagementIOProcessor.Counter
tigase.server.xmppclient.StreamManagementIOProcessor.OutQueue
- Enclosing class:
- StreamManagementIOProcessor
public static class StreamManagementIOProcessor.OutQueue
extends StreamManagementIOProcessor.Counter
OutQueue class implements queue of outgoing packets waiting for ack with implementation of removing acked
elements when id of acked packet is passed
-
Nested Class Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
ack
(int value) Confirm delivery of packets up to count passed as valueboolean
Deprecated.boolean
Append packet to waiting for ack queueprotected long
Method returns timestamp of the last received ack.protected long
Method returns timestamp of the last request for ack being sent.getQueue()
Method returns internal queue with packets waiting for ack - use testing only!protected boolean
gotAckOrSentRequestSince
(long since) Method checks if any ack was received or request for ack was sent since passed timestamp.void
Method notifies class that request for ack is being sentvoid
setAckRequestCount
(int ackRequestCount) Sets ack request count valuevoid
setResumptionEnabled
(boolean enabled) Deprecated.protected int
Method returns no.int
Returns size of queue containing packets waiting for ackMethods inherited from class tigase.server.xmppclient.StreamManagementIOProcessor.Counter
get, inc, setCounter
-
Constructor Details
-
OutQueue
public OutQueue()
-
-
Method Details
-
append
Deprecated.Append packet to waiting for ack queue -
append
Append packet to waiting for ack queue -
ack
public void ack(int value) Confirm delivery of packets up to count passed as value -
sendingRequest
public void sendingRequest()Method notifies class that request for ack is being sent -
setAckRequestCount
public void setAckRequestCount(int ackRequestCount) Sets ack request count value- Parameters:
ackRequestCount
-
-
setResumptionEnabled
Deprecated. -
waitingForAck
public int waitingForAck()Returns size of queue containing packets waiting for ack -
getQueue
Method returns internal queue with packets waiting for ack - use testing only! -
getLastConfirmationAt
protected long getLastConfirmationAt()Method returns timestamp of the last received ack.- Returns:
-
getLastRequestSentAt
protected long getLastRequestSentAt()Method returns timestamp of the last request for ack being sent.- Returns:
-
gotAckOrSentRequestSince
protected boolean gotAckOrSentRequestSince(long since) Method checks if any ack was received or request for ack was sent since passed timestamp.- Parameters:
since
-- Returns:
-
unackedSinceLastRequest
protected int unackedSinceLastRequest()Method returns no. of unacked stanzas since last request for ack was sent.- Returns:
-