Class ProtonSessionIncomingWindow
- java.lang.Object
-
- org.apache.qpid.protonj2.engine.impl.ProtonSessionIncomingWindow
-
public class ProtonSessionIncomingWindow extends Object
Tracks the incoming window and provides management of that window in relation to receiver links.The incoming window decreases as
Transfer
frames arrive and is replenished when the user reads the bytes received in the accumulated payload of a delivery. The window is expanded by sending aFlow
frame to the remote with an updated incoming window value at configured intervals based on reads from the pending deliveries.
-
-
Constructor Summary
Constructors Constructor Description ProtonSessionIncomingWindow(ProtonSession session)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description long
getIncomingBytes()
int
getIncomingCapacity()
long
getIncomingWindow()
long
getNextIncomingId()
int
getRemainingIncomingCapacity()
void
setIncomingCapacity(int incomingCapacity)
-
-
-
Constructor Detail
-
ProtonSessionIncomingWindow
public ProtonSessionIncomingWindow(ProtonSession session)
-
-
Method Detail
-
setIncomingCapacity
public void setIncomingCapacity(int incomingCapacity)
-
getIncomingCapacity
public int getIncomingCapacity()
-
getRemainingIncomingCapacity
public int getRemainingIncomingCapacity()
-
getIncomingBytes
public long getIncomingBytes()
-
getNextIncomingId
public long getNextIncomingId()
-
getIncomingWindow
public long getIncomingWindow()
-
-