Class Flow
- java.lang.Object
-
- org.apache.qpid.protonj2.types.transport.Flow
-
- All Implemented Interfaces:
Performative
public final class Flow extends java.lang.Object implements Performative
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.qpid.protonj2.types.transport.Performative
Performative.PerformativeHandler<E>, Performative.PerformativeType
-
-
Field Summary
Fields Modifier and Type Field Description static UnsignedLong
DESCRIPTOR_CODE
static Symbol
DESCRIPTOR_SYMBOL
-
Constructor Summary
Constructors Constructor Description Flow()
-
Method Summary
-
-
-
Field Detail
-
DESCRIPTOR_CODE
public static final UnsignedLong DESCRIPTOR_CODE
-
DESCRIPTOR_SYMBOL
public static final Symbol DESCRIPTOR_SYMBOL
-
-
Method Detail
-
isEmpty
public boolean isEmpty()
-
getElementCount
public int getElementCount()
-
hasNextIncomingId
public boolean hasNextIncomingId()
-
hasIncomingWindow
public boolean hasIncomingWindow()
-
hasNextOutgoingId
public boolean hasNextOutgoingId()
-
hasOutgoingWindow
public boolean hasOutgoingWindow()
-
hasHandle
public boolean hasHandle()
-
hasDeliveryCount
public boolean hasDeliveryCount()
-
hasLinkCredit
public boolean hasLinkCredit()
-
hasAvailable
public boolean hasAvailable()
-
hasDrain
public boolean hasDrain()
-
hasEcho
public boolean hasEcho()
-
hasProperties
public boolean hasProperties()
-
reset
public Flow reset()
-
getNextIncomingId
public long getNextIncomingId()
-
setNextIncomingId
public Flow setNextIncomingId(int nextIncomingId)
-
setNextIncomingId
public Flow setNextIncomingId(long nextIncomingId)
-
clearNextIncomingId
public Flow clearNextIncomingId()
-
getIncomingWindow
public long getIncomingWindow()
-
setIncomingWindow
public Flow setIncomingWindow(int incomingWindow)
-
setIncomingWindow
public Flow setIncomingWindow(long incomingWindow)
-
clearIncomingWindow
public Flow clearIncomingWindow()
-
getNextOutgoingId
public long getNextOutgoingId()
-
setNextOutgoingId
public Flow setNextOutgoingId(int nextOutgoingId)
-
setNextOutgoingId
public Flow setNextOutgoingId(long nextOutgoingId)
-
clearNextOutgoingId
public Flow clearNextOutgoingId()
-
getOutgoingWindow
public long getOutgoingWindow()
-
setOutgoingWindow
public Flow setOutgoingWindow(int outgoingWindow)
-
setOutgoingWindow
public Flow setOutgoingWindow(long outgoingWindow)
-
clearOutgoingWindow
public Flow clearOutgoingWindow()
-
getHandle
public long getHandle()
-
setHandle
public Flow setHandle(int handle)
-
setHandle
public Flow setHandle(long handle)
-
clearHandle
public Flow clearHandle()
-
getDeliveryCount
public long getDeliveryCount()
-
setDeliveryCount
public Flow setDeliveryCount(int deliveryCount)
-
setDeliveryCount
public Flow setDeliveryCount(long deliveryCount)
-
clearDeliveryCount
public Flow clearDeliveryCount()
-
getLinkCredit
public long getLinkCredit()
-
setLinkCredit
public Flow setLinkCredit(int linkCredit)
-
setLinkCredit
public Flow setLinkCredit(long linkCredit)
-
clearLinkCredit
public Flow clearLinkCredit()
-
getAvailable
public long getAvailable()
-
setAvailable
public Flow setAvailable(int available)
-
setAvailable
public Flow setAvailable(long available)
-
clearAvailable
public Flow clearAvailable()
-
getDrain
public boolean getDrain()
-
setDrain
public Flow setDrain(boolean drain)
-
clearDrain
public Flow clearDrain()
-
getEcho
public boolean getEcho()
-
setEcho
public Flow setEcho(boolean echo)
-
clearEcho
public Flow clearEcho()
-
getProperties
public java.util.Map<Symbol,java.lang.Object> getProperties()
-
clearProperties
public Flow clearProperties()
-
copy
public Flow copy()
- Specified by:
copy
in interfacePerformative
-
getPerformativeType
public Performative.PerformativeType getPerformativeType()
- Specified by:
getPerformativeType
in interfacePerformative
-
invoke
public <E> void invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
- Specified by:
invoke
in interfacePerformative
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-