public class org.apache.qpid.proton.message.impl.MessageImpl extends java.lang.Object implements org.apache.qpid.proton.message.ProtonJMessage
{
private org.apache.qpid.proton.amqp.messaging.Header _header;
private org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations _deliveryAnnotations;
private org.apache.qpid.proton.amqp.messaging.MessageAnnotations _messageAnnotations;
private org.apache.qpid.proton.amqp.messaging.Properties _properties;
private org.apache.qpid.proton.amqp.messaging.ApplicationProperties _applicationProperties;
private org.apache.qpid.proton.amqp.messaging.Section _body;
private org.apache.qpid.proton.amqp.messaging.Footer _footer;
private static final java.lang.ThreadLocal tlsCodec;
public void <init>()
{
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void <init>(org.apache.qpid.proton.amqp.messaging.Header, org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations, org.apache.qpid.proton.amqp.messaging.MessageAnnotations, org.apache.qpid.proton.amqp.messaging.Properties, org.apache.qpid.proton.amqp.messaging.ApplicationProperties, org.apache.qpid.proton.amqp.messaging.Section, org.apache.qpid.proton.amqp.messaging.Footer)
{
org.apache.qpid.proton.amqp.messaging.Footer v;
org.apache.qpid.proton.amqp.messaging.Header v;
org.apache.qpid.proton.amqp.messaging.Properties v;
org.apache.qpid.proton.message.impl.MessageImpl v;
org.apache.qpid.proton.amqp.messaging.ApplicationProperties v;
org.apache.qpid.proton.amqp.messaging.Section v;
org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations v;
org.apache.qpid.proton.amqp.messaging.MessageAnnotations v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: org.apache.qpid.proton.amqp.messaging.Header;
v := @parameter: org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations;
v := @parameter: org.apache.qpid.proton.amqp.messaging.MessageAnnotations;
v := @parameter: org.apache.qpid.proton.amqp.messaging.Properties;
v := @parameter: org.apache.qpid.proton.amqp.messaging.ApplicationProperties;
v := @parameter: org.apache.qpid.proton.amqp.messaging.Section;
v := @parameter: org.apache.qpid.proton.amqp.messaging.Footer;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header> = v;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations _deliveryAnnotations> = v;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.MessageAnnotations _messageAnnotations> = v;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties> = v;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.ApplicationProperties _applicationProperties> = v;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Section _body> = v;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Footer _footer> = v;
return;
}
public boolean isDurable()
{
org.apache.qpid.proton.amqp.messaging.Header v, v, v;
java.lang.Boolean v, v;
org.apache.qpid.proton.message.impl.MessageImpl v;
boolean v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
if v == null goto label;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: java.lang.Boolean getDurable()>();
if v != null goto label;
label:
v = 0;
goto label;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: java.lang.Boolean getDurable()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
label:
return v;
}
public long getDeliveryCount()
{
org.apache.qpid.proton.amqp.messaging.Header v, v, v;
long v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
if v == null goto label;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: org.apache.qpid.proton.amqp.UnsignedInteger getDeliveryCount()>();
if v != null goto label;
label:
v = 0L;
goto label;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: org.apache.qpid.proton.amqp.UnsignedInteger getDeliveryCount()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: long longValue()>();
label:
return v;
}
public short getPriority()
{
short v;
org.apache.qpid.proton.amqp.messaging.Header v, v, v;
org.apache.qpid.proton.amqp.UnsignedByte v, v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
if v == null goto label;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: org.apache.qpid.proton.amqp.UnsignedByte getPriority()>();
if v != null goto label;
label:
v = 4;
goto label;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: org.apache.qpid.proton.amqp.UnsignedByte getPriority()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedByte: short shortValue()>();
label:
return v;
}
public boolean isFirstAcquirer()
{
org.apache.qpid.proton.amqp.messaging.Header v, v, v;
java.lang.Boolean v, v;
org.apache.qpid.proton.message.impl.MessageImpl v;
boolean v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
if v == null goto label;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: java.lang.Boolean getFirstAcquirer()>();
if v != null goto label;
label:
v = 0;
goto label;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: java.lang.Boolean getFirstAcquirer()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
label:
return v;
}
public long getTtl()
{
org.apache.qpid.proton.amqp.messaging.Header v, v, v;
long v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
if v == null goto label;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: org.apache.qpid.proton.amqp.UnsignedInteger getTtl()>();
if v != null goto label;
label:
v = 0L;
goto label;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: org.apache.qpid.proton.amqp.UnsignedInteger getTtl()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: long longValue()>();
label:
return v;
}
public void setDurable(boolean)
{
org.apache.qpid.proton.amqp.messaging.Header v, v, v;
java.lang.Boolean v;
org.apache.qpid.proton.message.impl.MessageImpl v;
boolean v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: boolean;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
if v != null goto label;
if v == 0 goto label;
v = new org.apache.qpid.proton.amqp.messaging.Header;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header> = v;
goto label;
label:
return;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: void setDurable(java.lang.Boolean)>(v);
return;
}
public void setTtl(long)
{
org.apache.qpid.proton.amqp.messaging.Header v, v, v;
byte v;
long v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: long;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
if v != null goto label;
v = v cmp 0L;
if v == 0 goto label;
v = new org.apache.qpid.proton.amqp.messaging.Header;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header> = v;
goto label;
label:
return;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
v = staticinvoke <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger valueOf(long)>(v);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: void setTtl(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
return;
}
public void setDeliveryCount(long)
{
org.apache.qpid.proton.amqp.messaging.Header v, v, v;
byte v;
long v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: long;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
if v != null goto label;
v = v cmp 0L;
if v != 0 goto label;
return;
label:
v = new org.apache.qpid.proton.amqp.messaging.Header;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header> = v;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
v = staticinvoke <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger valueOf(long)>(v);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: void setDeliveryCount(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
return;
}
public void setFirstAcquirer(boolean)
{
org.apache.qpid.proton.amqp.messaging.Header v, v, v;
java.lang.Boolean v;
org.apache.qpid.proton.message.impl.MessageImpl v;
boolean v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: boolean;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
if v != null goto label;
if v != 0 goto label;
return;
label:
v = new org.apache.qpid.proton.amqp.messaging.Header;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header> = v;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: void setFirstAcquirer(java.lang.Boolean)>(v);
return;
}
public void setPriority(short)
{
short v;
org.apache.qpid.proton.amqp.messaging.Header v, v, v;
org.apache.qpid.proton.amqp.UnsignedByte v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: short;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
if v != null goto label;
if v != 4 goto label;
return;
label:
v = new org.apache.qpid.proton.amqp.messaging.Header;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header> = v;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
v = staticinvoke <org.apache.qpid.proton.amqp.UnsignedByte: org.apache.qpid.proton.amqp.UnsignedByte valueOf(byte)>(v);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: void setPriority(org.apache.qpid.proton.amqp.UnsignedByte)>(v);
return;
}
public java.lang.Object getMessageId()
{
org.apache.qpid.proton.amqp.messaging.Properties v, v;
java.lang.Object v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
v = null;
goto label;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.Object getMessageId()>();
label:
return v;
}
public long getGroupSequence()
{
int v;
org.apache.qpid.proton.amqp.messaging.Properties v, v, v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v == null goto label;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: org.apache.qpid.proton.amqp.UnsignedInteger getGroupSequence()>();
if v == null goto label;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: org.apache.qpid.proton.amqp.UnsignedInteger getGroupSequence()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: int intValue()>();
label:
return v;
}
public java.lang.String getReplyToGroupId()
{
org.apache.qpid.proton.amqp.messaging.Properties v, v;
java.lang.String v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
v = null;
goto label;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.String getReplyToGroupId()>();
label:
return v;
}
public long getCreationTime()
{
java.util.Date v, v;
org.apache.qpid.proton.amqp.messaging.Properties v, v, v;
long v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v == null goto label;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.util.Date getCreationTime()>();
if v != null goto label;
label:
v = 0L;
goto label;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.util.Date getCreationTime()>();
v = virtualinvoke v.<java.util.Date: long getTime()>();
label:
return v;
}
public java.lang.String getAddress()
{
org.apache.qpid.proton.amqp.messaging.Properties v, v;
java.lang.String v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
v = null;
goto label;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.String getTo()>();
label:
return v;
}
public byte[] getUserId()
{
byte[] v, v;
org.apache.qpid.proton.amqp.messaging.Properties v, v, v;
org.apache.qpid.proton.message.impl.MessageImpl v;
int v, v, v;
org.apache.qpid.proton.amqp.Binary v, v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v == null goto label;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: org.apache.qpid.proton.amqp.Binary getUserId()>();
if v != null goto label;
label:
return null;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: org.apache.qpid.proton.amqp.Binary getUserId()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Binary: int getLength()>();
v = newarray (byte)[v];
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Binary: byte[] getArray()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Binary: int getArrayOffset()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Binary: int getLength()>();
staticinvoke <java.lang.System: void arraycopy(java.lang.Object,int,java.lang.Object,int,int)>(v, v, v, 0, v);
return v;
}
public java.lang.String getReplyTo()
{
org.apache.qpid.proton.amqp.messaging.Properties v, v;
java.lang.String v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
v = null;
goto label;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.String getReplyTo()>();
label:
return v;
}
public java.lang.String getGroupId()
{
org.apache.qpid.proton.amqp.messaging.Properties v, v;
java.lang.String v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
v = null;
goto label;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.String getGroupId()>();
label:
return v;
}
public java.lang.String getContentType()
{
org.apache.qpid.proton.amqp.Symbol v, v;
org.apache.qpid.proton.amqp.messaging.Properties v, v, v;
java.lang.String v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v == null goto label;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: org.apache.qpid.proton.amqp.Symbol getContentType()>();
if v != null goto label;
label:
v = null;
goto label;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: org.apache.qpid.proton.amqp.Symbol getContentType()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Symbol: java.lang.String toString()>();
label:
return v;
}
public long getExpiryTime()
{
java.util.Date v, v;
org.apache.qpid.proton.amqp.messaging.Properties v, v, v;
long v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v == null goto label;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.util.Date getAbsoluteExpiryTime()>();
if v != null goto label;
label:
v = 0L;
goto label;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.util.Date getAbsoluteExpiryTime()>();
v = virtualinvoke v.<java.util.Date: long getTime()>();
label:
return v;
}
public java.lang.Object getCorrelationId()
{
org.apache.qpid.proton.amqp.messaging.Properties v, v;
java.lang.Object v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
v = null;
goto label;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.Object getCorrelationId()>();
label:
return v;
}
public java.lang.String getContentEncoding()
{
org.apache.qpid.proton.amqp.Symbol v, v;
org.apache.qpid.proton.amqp.messaging.Properties v, v, v;
java.lang.String v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v == null goto label;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: org.apache.qpid.proton.amqp.Symbol getContentEncoding()>();
if v != null goto label;
label:
v = null;
goto label;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: org.apache.qpid.proton.amqp.Symbol getContentEncoding()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Symbol: java.lang.String toString()>();
label:
return v;
}
public java.lang.String getSubject()
{
org.apache.qpid.proton.amqp.messaging.Properties v, v;
java.lang.String v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
v = null;
goto label;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.String getSubject()>();
label:
return v;
}
public void setGroupSequence(long)
{
byte v;
org.apache.qpid.proton.amqp.messaging.Properties v, v, v;
long v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: long;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
v = v cmp 0L;
if v != 0 goto label;
return;
label:
v = new org.apache.qpid.proton.amqp.messaging.Properties;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties> = v;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = staticinvoke <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger valueOf(int)>(v);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setGroupSequence(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
return;
}
public void setUserId(byte[])
{
byte[] v, v;
org.apache.qpid.proton.amqp.messaging.Properties v, v, v, v, v;
org.apache.qpid.proton.message.impl.MessageImpl v;
int v, v;
org.apache.qpid.proton.amqp.Binary v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: byte[];
if v != null goto label;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v == null goto label;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setUserId(org.apache.qpid.proton.amqp.Binary)>(null);
goto label;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
v = new org.apache.qpid.proton.amqp.messaging.Properties;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties> = v;
label:
v = lengthof v;
v = newarray (byte)[v];
v = lengthof v;
staticinvoke <java.lang.System: void arraycopy(java.lang.Object,int,java.lang.Object,int,int)>(v, 0, v, 0, v);
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = new org.apache.qpid.proton.amqp.Binary;
specialinvoke v.<org.apache.qpid.proton.amqp.Binary: void <init>(byte[])>(v);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setUserId(org.apache.qpid.proton.amqp.Binary)>(v);
label:
return;
}
public void setCreationTime(long)
{
byte v;
java.util.Date v;
org.apache.qpid.proton.amqp.messaging.Properties v, v, v;
long v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: long;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
v = v cmp 0L;
if v != 0 goto label;
return;
label:
v = new org.apache.qpid.proton.amqp.messaging.Properties;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties> = v;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>(long)>(v);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setCreationTime(java.util.Date)>(v);
return;
}
public void setSubject(java.lang.String)
{
org.apache.qpid.proton.amqp.messaging.Properties v, v, v;
java.lang.String v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: java.lang.String;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
if v != null goto label;
return;
label:
v = new org.apache.qpid.proton.amqp.messaging.Properties;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties> = v;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setSubject(java.lang.String)>(v);
return;
}
public void setGroupId(java.lang.String)
{
org.apache.qpid.proton.amqp.messaging.Properties v, v, v;
java.lang.String v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: java.lang.String;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
if v != null goto label;
return;
label:
v = new org.apache.qpid.proton.amqp.messaging.Properties;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties> = v;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setGroupId(java.lang.String)>(v);
return;
}
public void setAddress(java.lang.String)
{
org.apache.qpid.proton.amqp.messaging.Properties v, v, v;
java.lang.String v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: java.lang.String;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
if v != null goto label;
return;
label:
v = new org.apache.qpid.proton.amqp.messaging.Properties;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties> = v;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setTo(java.lang.String)>(v);
return;
}
public void setExpiryTime(long)
{
byte v;
java.util.Date v;
org.apache.qpid.proton.amqp.messaging.Properties v, v, v;
long v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: long;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
v = v cmp 0L;
if v != 0 goto label;
return;
label:
v = new org.apache.qpid.proton.amqp.messaging.Properties;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties> = v;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>(long)>(v);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setAbsoluteExpiryTime(java.util.Date)>(v);
return;
}
public void setReplyToGroupId(java.lang.String)
{
org.apache.qpid.proton.amqp.messaging.Properties v, v, v;
java.lang.String v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: java.lang.String;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
if v != null goto label;
return;
label:
v = new org.apache.qpid.proton.amqp.messaging.Properties;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties> = v;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setReplyToGroupId(java.lang.String)>(v);
return;
}
public void setContentEncoding(java.lang.String)
{
org.apache.qpid.proton.amqp.Symbol v;
org.apache.qpid.proton.amqp.messaging.Properties v, v, v;
java.lang.String v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: java.lang.String;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
if v != null goto label;
return;
label:
v = new org.apache.qpid.proton.amqp.messaging.Properties;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties> = v;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = staticinvoke <org.apache.qpid.proton.amqp.Symbol: org.apache.qpid.proton.amqp.Symbol valueOf(java.lang.String)>(v);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setContentEncoding(org.apache.qpid.proton.amqp.Symbol)>(v);
return;
}
public void setContentType(java.lang.String)
{
org.apache.qpid.proton.amqp.Symbol v;
org.apache.qpid.proton.amqp.messaging.Properties v, v, v;
java.lang.String v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: java.lang.String;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
if v != null goto label;
return;
label:
v = new org.apache.qpid.proton.amqp.messaging.Properties;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties> = v;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
v = staticinvoke <org.apache.qpid.proton.amqp.Symbol: org.apache.qpid.proton.amqp.Symbol valueOf(java.lang.String)>(v);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setContentType(org.apache.qpid.proton.amqp.Symbol)>(v);
return;
}
public void setReplyTo(java.lang.String)
{
org.apache.qpid.proton.amqp.messaging.Properties v, v, v;
java.lang.String v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: java.lang.String;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
if v != null goto label;
return;
label:
v = new org.apache.qpid.proton.amqp.messaging.Properties;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties> = v;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setReplyTo(java.lang.String)>(v);
return;
}
public void setCorrelationId(java.lang.Object)
{
org.apache.qpid.proton.amqp.messaging.Properties v, v, v;
java.lang.Object v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: java.lang.Object;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
if v != null goto label;
return;
label:
v = new org.apache.qpid.proton.amqp.messaging.Properties;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties> = v;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setCorrelationId(java.lang.Object)>(v);
return;
}
public void setMessageId(java.lang.Object)
{
org.apache.qpid.proton.amqp.messaging.Properties v, v, v;
java.lang.Object v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: java.lang.Object;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v != null goto label;
if v != null goto label;
return;
label:
v = new org.apache.qpid.proton.amqp.messaging.Properties;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void <init>()>();
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties> = v;
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setMessageId(java.lang.Object)>(v);
return;
}
public org.apache.qpid.proton.amqp.messaging.Header getHeader()
{
org.apache.qpid.proton.amqp.messaging.Header v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
return v;
}
public org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations getDeliveryAnnotations()
{
org.apache.qpid.proton.message.impl.MessageImpl v;
org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations _deliveryAnnotations>;
return v;
}
public org.apache.qpid.proton.amqp.messaging.MessageAnnotations getMessageAnnotations()
{
org.apache.qpid.proton.amqp.messaging.MessageAnnotations v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.MessageAnnotations _messageAnnotations>;
return v;
}
public org.apache.qpid.proton.amqp.messaging.Properties getProperties()
{
org.apache.qpid.proton.amqp.messaging.Properties v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
return v;
}
public org.apache.qpid.proton.amqp.messaging.ApplicationProperties getApplicationProperties()
{
org.apache.qpid.proton.message.impl.MessageImpl v;
org.apache.qpid.proton.amqp.messaging.ApplicationProperties v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.ApplicationProperties _applicationProperties>;
return v;
}
public org.apache.qpid.proton.amqp.messaging.Section getBody()
{
org.apache.qpid.proton.amqp.messaging.Section v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Section _body>;
return v;
}
public org.apache.qpid.proton.amqp.messaging.Footer getFooter()
{
org.apache.qpid.proton.amqp.messaging.Footer v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Footer _footer>;
return v;
}
public void setHeader(org.apache.qpid.proton.amqp.messaging.Header)
{
org.apache.qpid.proton.amqp.messaging.Header v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: org.apache.qpid.proton.amqp.messaging.Header;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header> = v;
return;
}
public void setDeliveryAnnotations(org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations)
{
org.apache.qpid.proton.message.impl.MessageImpl v;
org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations _deliveryAnnotations> = v;
return;
}
public void setMessageAnnotations(org.apache.qpid.proton.amqp.messaging.MessageAnnotations)
{
org.apache.qpid.proton.amqp.messaging.MessageAnnotations v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: org.apache.qpid.proton.amqp.messaging.MessageAnnotations;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.MessageAnnotations _messageAnnotations> = v;
return;
}
public void setProperties(org.apache.qpid.proton.amqp.messaging.Properties)
{
org.apache.qpid.proton.amqp.messaging.Properties v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: org.apache.qpid.proton.amqp.messaging.Properties;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties> = v;
return;
}
public void setApplicationProperties(org.apache.qpid.proton.amqp.messaging.ApplicationProperties)
{
org.apache.qpid.proton.message.impl.MessageImpl v;
org.apache.qpid.proton.amqp.messaging.ApplicationProperties v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: org.apache.qpid.proton.amqp.messaging.ApplicationProperties;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.ApplicationProperties _applicationProperties> = v;
return;
}
public void setBody(org.apache.qpid.proton.amqp.messaging.Section)
{
org.apache.qpid.proton.amqp.messaging.Section v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: org.apache.qpid.proton.amqp.messaging.Section;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Section _body> = v;
return;
}
public void setFooter(org.apache.qpid.proton.amqp.messaging.Footer)
{
org.apache.qpid.proton.amqp.messaging.Footer v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: org.apache.qpid.proton.amqp.messaging.Footer;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Footer _footer> = v;
return;
}
public int decode(byte[], int, int)
{
byte[] v;
int v, v, v, v;
org.apache.qpid.proton.message.impl.MessageImpl v;
java.nio.ByteBuffer v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[],int,int)>(v, v, v);
virtualinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl: void decode(java.nio.ByteBuffer)>(v);
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
v = v - v;
return v;
}
public void decode(java.nio.ByteBuffer)
{
org.apache.qpid.proton.message.impl.MessageImpl v;
org.apache.qpid.proton.codec.ReadableBuffer$ByteBufferReader v;
java.nio.ByteBuffer v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: java.nio.ByteBuffer;
v = staticinvoke <org.apache.qpid.proton.codec.ReadableBuffer$ByteBufferReader: org.apache.qpid.proton.codec.ReadableBuffer$ByteBufferReader wrap(java.nio.ByteBuffer)>(v);
virtualinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl: void decode(org.apache.qpid.proton.codec.ReadableBuffer)>(v);
return;
}
public void decode(org.apache.qpid.proton.codec.ReadableBuffer)
{
org.apache.qpid.proton.message.impl.MessageImpl v;
org.apache.qpid.proton.codec.ReadableBuffer v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.ThreadLocal v;
java.lang.Object v, v;
org.apache.qpid.proton.codec.DecoderImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: org.apache.qpid.proton.codec.ReadableBuffer;
v = <org.apache.qpid.proton.message.impl.MessageImpl: java.lang.ThreadLocal tlsCodec>;
v = virtualinvoke v.<java.lang.ThreadLocal: java.lang.Object get()>();
v = v.<org.apache.qpid.proton.message.impl.MessageImpl$EncoderDecoderPair: org.apache.qpid.proton.codec.DecoderImpl decoder>;
virtualinvoke v.<org.apache.qpid.proton.codec.DecoderImpl: void setBuffer(org.apache.qpid.proton.codec.ReadableBuffer)>(v);
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header> = null;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations _deliveryAnnotations> = null;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.MessageAnnotations _messageAnnotations> = null;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties> = null;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.ApplicationProperties _applicationProperties> = null;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Section _body> = null;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Footer _footer> = null;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: boolean hasRemaining()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.qpid.proton.codec.DecoderImpl: java.lang.Object readObject()>();
label:
v = v instanceof org.apache.qpid.proton.amqp.messaging.Header;
if v == 0 goto label;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header> = null;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: boolean hasRemaining()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.qpid.proton.codec.DecoderImpl: java.lang.Object readObject()>();
goto label;
label:
v = null;
label:
v = v instanceof org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations;
if v == 0 goto label;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations _deliveryAnnotations> = null;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: boolean hasRemaining()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.qpid.proton.codec.DecoderImpl: java.lang.Object readObject()>();
goto label;
label:
v = null;
label:
v = v instanceof org.apache.qpid.proton.amqp.messaging.MessageAnnotations;
if v == 0 goto label;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.MessageAnnotations _messageAnnotations> = null;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: boolean hasRemaining()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.qpid.proton.codec.DecoderImpl: java.lang.Object readObject()>();
goto label;
label:
v = null;
label:
v = v instanceof org.apache.qpid.proton.amqp.messaging.Properties;
if v == 0 goto label;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties> = null;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: boolean hasRemaining()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.qpid.proton.codec.DecoderImpl: java.lang.Object readObject()>();
goto label;
label:
v = null;
label:
v = v instanceof org.apache.qpid.proton.amqp.messaging.ApplicationProperties;
if v == 0 goto label;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.ApplicationProperties _applicationProperties> = null;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: boolean hasRemaining()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.qpid.proton.codec.DecoderImpl: java.lang.Object readObject()>();
goto label;
label:
v = null;
label:
if v == null goto label;
v = v instanceof org.apache.qpid.proton.amqp.messaging.Footer;
if v != 0 goto label;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Section _body> = v;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: boolean hasRemaining()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.qpid.proton.codec.DecoderImpl: java.lang.Object readObject()>();
goto label;
label:
v = null;
label:
v = v instanceof org.apache.qpid.proton.amqp.messaging.Footer;
if v == 0 goto label;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Footer _footer> = null;
label:
virtualinvoke v.<org.apache.qpid.proton.codec.DecoderImpl: void setBuffer(org.apache.qpid.proton.codec.ReadableBuffer)>(null);
return;
}
public int encode(byte[], int, int)
{
byte[] v;
int v, v, v;
org.apache.qpid.proton.message.impl.MessageImpl v;
org.apache.qpid.proton.codec.WritableBuffer$ByteBufferWrapper v;
java.nio.ByteBuffer v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[],int,int)>(v, v, v);
v = new org.apache.qpid.proton.codec.WritableBuffer$ByteBufferWrapper;
specialinvoke v.<org.apache.qpid.proton.codec.WritableBuffer$ByteBufferWrapper: void <init>(java.nio.ByteBuffer)>(v);
v = virtualinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl: int encode(org.apache.qpid.proton.codec.WritableBuffer)>(v);
return v;
}
public int encode2(byte[], int, int)
{
byte[] v;
org.apache.qpid.proton.message.impl.MessageImpl v;
java.nio.ByteBuffer v;
int v, v, v, v, v;
org.apache.qpid.proton.codec.CompositeWritableBuffer v;
org.apache.qpid.proton.codec.DroppingWritableBuffer v;
org.apache.qpid.proton.codec.WritableBuffer$ByteBufferWrapper v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[],int,int)>(v, v, v);
v = new org.apache.qpid.proton.codec.WritableBuffer$ByteBufferWrapper;
specialinvoke v.<org.apache.qpid.proton.codec.WritableBuffer$ByteBufferWrapper: void <init>(java.nio.ByteBuffer)>(v);
v = new org.apache.qpid.proton.codec.DroppingWritableBuffer;
specialinvoke v.<org.apache.qpid.proton.codec.DroppingWritableBuffer: void <init>()>();
v = new org.apache.qpid.proton.codec.CompositeWritableBuffer;
specialinvoke v.<org.apache.qpid.proton.codec.CompositeWritableBuffer: void <init>(org.apache.qpid.proton.codec.WritableBuffer,org.apache.qpid.proton.codec.WritableBuffer)>(v, v);
v = virtualinvoke v.<org.apache.qpid.proton.codec.CompositeWritableBuffer: int position()>();
virtualinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl: int encode(org.apache.qpid.proton.codec.WritableBuffer)>(v);
v = virtualinvoke v.<org.apache.qpid.proton.codec.CompositeWritableBuffer: int position()>();
v = v - v;
return v;
}
public int encode(org.apache.qpid.proton.codec.WritableBuffer)
{
org.apache.qpid.proton.amqp.messaging.Header v, v;
org.apache.qpid.proton.message.impl.MessageImpl v;
int v, v, v;
org.apache.qpid.proton.codec.WritableBuffer v, v;
java.lang.ThreadLocal v;
org.apache.qpid.proton.amqp.messaging.Footer v, v;
org.apache.qpid.proton.codec.EncoderImpl v;
org.apache.qpid.proton.amqp.messaging.Properties v, v;
org.apache.qpid.proton.amqp.messaging.ApplicationProperties v, v;
org.apache.qpid.proton.amqp.messaging.Section v, v;
org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations v, v;
org.apache.qpid.proton.amqp.messaging.MessageAnnotations v, v;
java.lang.Object v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v := @parameter: org.apache.qpid.proton.codec.WritableBuffer;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.WritableBuffer: int remaining()>();
v = <org.apache.qpid.proton.message.impl.MessageImpl: java.lang.ThreadLocal tlsCodec>;
v = virtualinvoke v.<java.lang.ThreadLocal: java.lang.Object get()>();
v = v.<org.apache.qpid.proton.message.impl.MessageImpl$EncoderDecoderPair: org.apache.qpid.proton.codec.EncoderImpl encoder>;
virtualinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void setByteBuffer(org.apache.qpid.proton.codec.WritableBuffer)>(v);
v = virtualinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header getHeader()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header getHeader()>();
virtualinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void writeObject(java.lang.Object)>(v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations getDeliveryAnnotations()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations getDeliveryAnnotations()>();
virtualinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void writeObject(java.lang.Object)>(v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.MessageAnnotations getMessageAnnotations()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.MessageAnnotations getMessageAnnotations()>();
virtualinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void writeObject(java.lang.Object)>(v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties getProperties()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties getProperties()>();
virtualinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void writeObject(java.lang.Object)>(v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.ApplicationProperties getApplicationProperties()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.ApplicationProperties getApplicationProperties()>();
virtualinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void writeObject(java.lang.Object)>(v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Section getBody()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Section getBody()>();
virtualinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void writeObject(java.lang.Object)>(v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Footer getFooter()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Footer getFooter()>();
virtualinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void writeObject(java.lang.Object)>(v);
label:
v = null;
virtualinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void setByteBuffer(org.apache.qpid.proton.codec.WritableBuffer)>(v);
v = interfaceinvoke v.<org.apache.qpid.proton.codec.WritableBuffer: int remaining()>();
v = v - v;
return v;
}
public void clear()
{
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Section _body> = null;
return;
}
public org.apache.qpid.proton.message.MessageError getError()
{
org.apache.qpid.proton.message.MessageError v;
org.apache.qpid.proton.message.impl.MessageImpl v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = <org.apache.qpid.proton.message.MessageError: org.apache.qpid.proton.message.MessageError OK>;
return v;
}
public java.lang.String toString()
{
org.apache.qpid.proton.amqp.messaging.Header v, v;
org.apache.qpid.proton.amqp.messaging.Properties v, v;
org.apache.qpid.proton.message.impl.MessageImpl v;
org.apache.qpid.proton.amqp.messaging.Section v, v;
org.apache.qpid.proton.amqp.messaging.MessageAnnotations v, v;
java.lang.StringBuilder v;
java.lang.String v;
v := @this: org.apache.qpid.proton.message.impl.MessageImpl;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("Message{");
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
if v == null goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("header=");
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Header _header>;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
if v == null goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("properties=");
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Properties _properties>;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.MessageAnnotations _messageAnnotations>;
if v == null goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("message_annotations=");
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.MessageAnnotations _messageAnnotations>;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
label:
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Section _body>;
if v == null goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("body=");
v = v.<org.apache.qpid.proton.message.impl.MessageImpl: org.apache.qpid.proton.amqp.messaging.Section _body>;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("}");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
static void <clinit>()
{
org.apache.qpid.proton.message.impl.MessageImpl$1 v;
v = new org.apache.qpid.proton.message.impl.MessageImpl$1;
specialinvoke v.<org.apache.qpid.proton.message.impl.MessageImpl$1: void <init>()>();
<org.apache.qpid.proton.message.impl.MessageImpl: java.lang.ThreadLocal tlsCodec> = v;
return;
}
}