Package org.apache.qpid.protonj2.types.transport

Class Flow

java.lang.Object
org.apache.qpid.protonj2.types.transport.Flow
All Implemented Interfaces:
Performative
public final class Flow extends Object implements Performative

  • Field Details

    • DESCRIPTOR_CODE

      public static final UnsignedLong DESCRIPTOR_CODE

    • DESCRIPTOR_SYMBOL

      public static final Symbol DESCRIPTOR_SYMBOL

  • Constructor Details

    • Flow

      public Flow()

  • Method Details

    • isEmpty

      public boolean isEmpty()

    • getElementCount

      public int getElementCount()

    • hasElement

      public boolean hasElement(int index)

    • 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 Map<Symbol,Object> getProperties()

    • setProperties

      public Flow setProperties(Map<Symbol,Object> properties)

    • clearProperties

      public Flow clearProperties()

    • copy

      public Flow copy()
      Specified by:
      copy in interface Performative

    • getPerformativeType

      public Performative.PerformativeType getPerformativeType()
      Specified by:
      getPerformativeType in interface Performative

    • invoke

      public <E> void invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
      Specified by:
      invoke in interface Performative

    • toString

      public String toString()
      Overrides:
      toString in class Object