public static class StreamManagementIOProcessor.OutQueue extends StreamManagementIOProcessor.Counter
Modifier and Type | Class and Description |
---|---|
class |
StreamManagementIOProcessor.OutQueue.Entry |
Constructor and Description |
---|
OutQueue() |
Modifier and Type | Method and Description |
---|---|
void |
ack(int value)
Confirm delivery of packets up to count passed as value
|
void |
append(Packet packet)
Append packet to waiting for ack queue
|
protected ArrayDeque<StreamManagementIOProcessor.OutQueue.Entry> |
getQueue()
Method returns internal queue with packets waiting for ack - use testing
only!
|
void |
setResumptionEnabled(boolean enabled) |
int |
waitingForAck()
Returns size of queue containing packets waiting for ack
|
get, inc, setCounter
public void append(Packet packet)
packet
- public void ack(int value)
value
- public void setResumptionEnabled(boolean enabled)
public int waitingForAck()
protected ArrayDeque<StreamManagementIOProcessor.OutQueue.Entry> getQueue()
Copyright © 2019 "Tigase, Inc.". All rights reserved.