public final class org.apache.qpid.proton.amqp.transport.Flow extends java.lang.Object implements org.apache.qpid.proton.amqp.transport.FrameBody
{
private org.apache.qpid.proton.amqp.UnsignedInteger _nextIncomingId;
private org.apache.qpid.proton.amqp.UnsignedInteger _incomingWindow;
private org.apache.qpid.proton.amqp.UnsignedInteger _nextOutgoingId;
private org.apache.qpid.proton.amqp.UnsignedInteger _outgoingWindow;
private org.apache.qpid.proton.amqp.UnsignedInteger _handle;
private org.apache.qpid.proton.amqp.UnsignedInteger _deliveryCount;
private org.apache.qpid.proton.amqp.UnsignedInteger _linkCredit;
private org.apache.qpid.proton.amqp.UnsignedInteger _available;
private boolean _drain;
private boolean _echo;
private java.util.Map _properties;
public void <init>()
{
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void <init>(org.apache.qpid.proton.amqp.transport.Flow)
{
org.apache.qpid.proton.amqp.UnsignedInteger v, v, v, v, v, v, v, v;
java.util.LinkedHashMap v;
java.util.Map v, v;
org.apache.qpid.proton.amqp.transport.Flow v, v;
boolean v, v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v := @parameter: org.apache.qpid.proton.amqp.transport.Flow;
specialinvoke v.<java.lang.Object: void <init>()>();
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _nextIncomingId>;
v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _nextIncomingId> = v;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _incomingWindow>;
v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _incomingWindow> = v;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _nextOutgoingId>;
v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _nextOutgoingId> = v;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _outgoingWindow>;
v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _outgoingWindow> = v;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _handle>;
v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _handle> = v;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _deliveryCount>;
v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _deliveryCount> = v;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _linkCredit>;
v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _linkCredit> = v;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _available>;
v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _available> = v;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: boolean _drain>;
v.<org.apache.qpid.proton.amqp.transport.Flow: boolean _drain> = v;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: boolean _echo>;
v.<org.apache.qpid.proton.amqp.transport.Flow: boolean _echo> = v;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: java.util.Map _properties>;
if v == null goto label;
v = new java.util.LinkedHashMap;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: java.util.Map _properties>;
specialinvoke v.<java.util.LinkedHashMap: void <init>(java.util.Map)>(v);
v.<org.apache.qpid.proton.amqp.transport.Flow: java.util.Map _properties> = v;
label:
return;
}
public org.apache.qpid.proton.amqp.UnsignedInteger getNextIncomingId()
{
org.apache.qpid.proton.amqp.UnsignedInteger v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _nextIncomingId>;
return v;
}
public void setNextIncomingId(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.amqp.UnsignedInteger v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _nextIncomingId> = v;
return;
}
public org.apache.qpid.proton.amqp.UnsignedInteger getIncomingWindow()
{
org.apache.qpid.proton.amqp.UnsignedInteger v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _incomingWindow>;
return v;
}
public void setIncomingWindow(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.amqp.UnsignedInteger v;
java.lang.NullPointerException v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
if v != null goto label;
v = new java.lang.NullPointerException;
specialinvoke v.<java.lang.NullPointerException: void <init>(java.lang.String)>("the incoming-window field is mandatory");
throw v;
label:
v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _incomingWindow> = v;
return;
}
public org.apache.qpid.proton.amqp.UnsignedInteger getNextOutgoingId()
{
org.apache.qpid.proton.amqp.UnsignedInteger v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _nextOutgoingId>;
return v;
}
public void setNextOutgoingId(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.amqp.UnsignedInteger v;
java.lang.NullPointerException v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
if v != null goto label;
v = new java.lang.NullPointerException;
specialinvoke v.<java.lang.NullPointerException: void <init>(java.lang.String)>("the next-outgoing-id field is mandatory");
throw v;
label:
v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _nextOutgoingId> = v;
return;
}
public org.apache.qpid.proton.amqp.UnsignedInteger getOutgoingWindow()
{
org.apache.qpid.proton.amqp.UnsignedInteger v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _outgoingWindow>;
return v;
}
public void setOutgoingWindow(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.amqp.UnsignedInteger v;
java.lang.NullPointerException v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
if v != null goto label;
v = new java.lang.NullPointerException;
specialinvoke v.<java.lang.NullPointerException: void <init>(java.lang.String)>("the outgoing-window field is mandatory");
throw v;
label:
v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _outgoingWindow> = v;
return;
}
public org.apache.qpid.proton.amqp.UnsignedInteger getHandle()
{
org.apache.qpid.proton.amqp.UnsignedInteger v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _handle>;
return v;
}
public void setHandle(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.amqp.UnsignedInteger v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _handle> = v;
return;
}
public org.apache.qpid.proton.amqp.UnsignedInteger getDeliveryCount()
{
org.apache.qpid.proton.amqp.UnsignedInteger v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _deliveryCount>;
return v;
}
public void setDeliveryCount(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.amqp.UnsignedInteger v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _deliveryCount> = v;
return;
}
public org.apache.qpid.proton.amqp.UnsignedInteger getLinkCredit()
{
org.apache.qpid.proton.amqp.UnsignedInteger v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _linkCredit>;
return v;
}
public void setLinkCredit(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.amqp.UnsignedInteger v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _linkCredit> = v;
return;
}
public org.apache.qpid.proton.amqp.UnsignedInteger getAvailable()
{
org.apache.qpid.proton.amqp.UnsignedInteger v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _available>;
return v;
}
public void setAvailable(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.amqp.UnsignedInteger v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _available> = v;
return;
}
public boolean getDrain()
{
org.apache.qpid.proton.amqp.transport.Flow v;
boolean v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: boolean _drain>;
return v;
}
public void setDrain(boolean)
{
org.apache.qpid.proton.amqp.transport.Flow v;
boolean v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v := @parameter: boolean;
v.<org.apache.qpid.proton.amqp.transport.Flow: boolean _drain> = v;
return;
}
public boolean getEcho()
{
org.apache.qpid.proton.amqp.transport.Flow v;
boolean v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: boolean _echo>;
return v;
}
public void setEcho(boolean)
{
org.apache.qpid.proton.amqp.transport.Flow v;
boolean v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v := @parameter: boolean;
v.<org.apache.qpid.proton.amqp.transport.Flow: boolean _echo> = v;
return;
}
public java.util.Map getProperties()
{
org.apache.qpid.proton.amqp.transport.Flow v;
java.util.Map v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: java.util.Map _properties>;
return v;
}
public void setProperties(java.util.Map)
{
org.apache.qpid.proton.amqp.transport.Flow v;
java.util.Map v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v := @parameter: java.util.Map;
v.<org.apache.qpid.proton.amqp.transport.Flow: java.util.Map _properties> = v;
return;
}
public void invoke(org.apache.qpid.proton.amqp.transport.FrameBody$FrameBodyHandler, org.apache.qpid.proton.amqp.Binary, java.lang.Object)
{
org.apache.qpid.proton.amqp.transport.FrameBody$FrameBodyHandler v;
java.lang.Object v;
org.apache.qpid.proton.amqp.Binary v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v := @parameter: org.apache.qpid.proton.amqp.transport.FrameBody$FrameBodyHandler;
v := @parameter: org.apache.qpid.proton.amqp.Binary;
v := @parameter: java.lang.Object;
interfaceinvoke v.<org.apache.qpid.proton.amqp.transport.FrameBody$FrameBodyHandler: void handleFlow(org.apache.qpid.proton.amqp.transport.Flow,org.apache.qpid.proton.amqp.Binary,java.lang.Object)>(v, v, v);
return;
}
public java.lang.String toString()
{
org.apache.qpid.proton.amqp.UnsignedInteger v, v, v, v, v, v, v, v;
java.util.Map v;
java.lang.String v;
org.apache.qpid.proton.amqp.transport.Flow v;
boolean v, v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _nextIncomingId>;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _incomingWindow>;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _nextOutgoingId>;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _outgoingWindow>;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _handle>;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _deliveryCount>;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _linkCredit>;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger _available>;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: boolean _drain>;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: boolean _echo>;
v = v.<org.apache.qpid.proton.amqp.transport.Flow: java.util.Map _properties>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.qpid.proton.amqp.UnsignedInteger,org.apache.qpid.proton.amqp.UnsignedInteger,org.apache.qpid.proton.amqp.UnsignedInteger,org.apache.qpid.proton.amqp.UnsignedInteger,org.apache.qpid.proton.amqp.UnsignedInteger,org.apache.qpid.proton.amqp.UnsignedInteger,org.apache.qpid.proton.amqp.UnsignedInteger,org.apache.qpid.proton.amqp.UnsignedInteger,boolean,boolean,java.util.Map)>(v, v, v, v, v, v, v, v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Flow{nextIncomingId=\u, incomingWindow=\u, nextOutgoingId=\u, outgoingWindow=\u, handle=\u, deliveryCount=\u, linkCredit=\u, available=\u, drain=\u, echo=\u, properties=\u0001}");
return v;
}
public org.apache.qpid.proton.amqp.transport.Flow copy()
{
org.apache.qpid.proton.amqp.transport.Flow v, v;
v := @this: org.apache.qpid.proton.amqp.transport.Flow;
v = new org.apache.qpid.proton.amqp.transport.Flow;
specialinvoke v.<org.apache.qpid.proton.amqp.transport.Flow: void <init>(org.apache.qpid.proton.amqp.transport.Flow)>(v);
return v;
}
}