Package org.apache.qpid.protonj2.engine.impl

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 a Flow 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

Modifier and Type	Method	Description
long	getIncomingBytes()
int	getIncomingCapacity()
long	getIncomingWindow()
long	getNextIncomingId()
int	getRemainingIncomingCapacity()
void	setIncomingCapacity(int incomingCapacity)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ProtonSessionIncomingWindow

public ProtonSessionIncomingWindow(ProtonSession session)

Method Details

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()