public class org.apache.activemq.command.ActiveMQMessage extends org.apache.activemq.command.Message implements org.apache.activemq.Message, org.apache.activemq.ScheduledMessage
{
public static final byte DATA_STRUCTURE_TYPE;
public static final java.lang.String DLQ_DELIVERY_FAILURE_CAUSE_PROPERTY;
public static final java.lang.String BROKER_PATH_PROPERTY;
private static final java.util.Map JMS_PROPERTY_SETERS;
protected transient org.apache.activemq.util.Callback acknowledgeCallback;
public void <init>()
{
org.apache.activemq.command.ActiveMQMessage v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
specialinvoke v.<org.apache.activemq.command.Message: void <init>()>();
return;
}
public byte getDataStructureType()
{
org.apache.activemq.command.ActiveMQMessage v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
return 23;
}
public org.apache.activemq.command.Message copy()
{
org.apache.activemq.command.ActiveMQMessage v, v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v = new org.apache.activemq.command.ActiveMQMessage;
specialinvoke v.<org.apache.activemq.command.ActiveMQMessage: void <init>()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void copy(org.apache.activemq.command.ActiveMQMessage)>(v);
return v;
}
protected void copy(org.apache.activemq.command.ActiveMQMessage)
{
org.apache.activemq.command.ActiveMQMessage v, v;
org.apache.activemq.util.Callback v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: org.apache.activemq.command.ActiveMQMessage;
specialinvoke v.<org.apache.activemq.command.Message: void copy(org.apache.activemq.command.Message)>(v);
v = v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.util.Callback acknowledgeCallback>;
v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.util.Callback acknowledgeCallback> = v;
return;
}
public int hashCode()
{
org.apache.activemq.command.MessageId v;
int v, v;
org.apache.activemq.command.ActiveMQMessage v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.command.MessageId getMessageId()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.command.MessageId: int hashCode()>();
return v;
label:
v = specialinvoke v.<java.lang.Object: int hashCode()>();
return v;
}
public boolean equals(java.lang.Object)
{
org.apache.activemq.command.MessageId v, v;
org.apache.activemq.command.ActiveMQMessage v;
java.lang.Class v, v;
java.lang.Object v;
boolean v, v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.Object;
if v != v goto label;
return 1;
label:
if v == null goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
if v == v goto label;
label:
return 0;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.command.MessageId getMessageId()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.command.MessageId getMessageId()>();
if v == null goto label;
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.command.MessageId: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public void acknowledge() throws javax.jms.JMSException
{
java.lang.Throwable v;
org.apache.activemq.util.Callback v, v;
org.apache.activemq.command.ActiveMQMessage v;
javax.jms.JMSException v, v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v = v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.util.Callback acknowledgeCallback>;
if v == null goto label;
label:
v = v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.util.Callback acknowledgeCallback>;
interfaceinvoke v.<org.apache.activemq.util.Callback: void execute()>();
label:
goto label;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
v = staticinvoke <org.apache.activemq.util.JMSExceptionSupport: javax.jms.JMSException create(java.lang.Throwable)>(v);
throw v;
label:
return;
catch javax.jms.JMSException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void clearBody() throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQMessage v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setContent(org.apache.activemq.util.ByteSequence)>(null);
v.<org.apache.activemq.command.ActiveMQMessage: boolean readOnlyBody> = 0;
return;
}
public java.lang.String getJMSMessageID()
{
org.apache.activemq.command.ActiveMQMessage v;
java.lang.String v;
org.apache.activemq.command.MessageId v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.command.MessageId getMessageId()>();
if v != null goto label;
return null;
label:
v = virtualinvoke v.<org.apache.activemq.command.MessageId: java.lang.String toString()>();
return v;
}
public void setJMSMessageID(java.lang.String) throws javax.jms.JMSException
{
org.apache.activemq.command.MessageId v, v;
org.apache.activemq.command.ActiveMQMessage v;
java.lang.NumberFormatException v;
java.lang.String v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
if v == null goto label;
label:
v = new org.apache.activemq.command.MessageId;
specialinvoke v.<org.apache.activemq.command.MessageId: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setMessageId(org.apache.activemq.command.MessageId)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.activemq.command.MessageId;
specialinvoke v.<org.apache.activemq.command.MessageId: void <init>()>();
virtualinvoke v.<org.apache.activemq.command.MessageId: void setTextView(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setMessageId(org.apache.activemq.command.MessageId)>(v);
goto label;
label:
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setMessageId(org.apache.activemq.command.MessageId)>(null);
label:
return;
catch java.lang.NumberFormatException from label to label with label;
}
public void setJMSMessageID(org.apache.activemq.command.ProducerId, long) throws javax.jms.JMSException
{
java.lang.Throwable v;
org.apache.activemq.command.MessageId v, v;
org.apache.activemq.command.ActiveMQMessage v;
long v;
javax.jms.JMSException v;
org.apache.activemq.command.ProducerId v;
java.lang.String v, v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: org.apache.activemq.command.ProducerId;
v := @parameter: long;
v = null;
label:
v = new org.apache.activemq.command.MessageId;
specialinvoke v.<org.apache.activemq.command.MessageId: void <init>(org.apache.activemq.command.ProducerId,long)>(v, v);
v = v;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setMessageId(org.apache.activemq.command.MessageId)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.Throwable: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.MessageId,java.lang.String)>(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[])>("Invalid message id \'\u0001\', reason: \u0001");
v = staticinvoke <org.apache.activemq.util.JMSExceptionSupport: javax.jms.JMSException create(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public long getJMSTimestamp()
{
org.apache.activemq.command.ActiveMQMessage v;
long v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: long getTimestamp()>();
return v;
}
public void setJMSTimestamp(long)
{
org.apache.activemq.command.ActiveMQMessage v;
long v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: long;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setTimestamp(long)>(v);
return;
}
public java.lang.String getJMSCorrelationID()
{
org.apache.activemq.command.ActiveMQMessage v;
java.lang.String v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.String getCorrelationId()>();
return v;
}
public void setJMSCorrelationID(java.lang.String)
{
org.apache.activemq.command.ActiveMQMessage v;
java.lang.String v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setCorrelationId(java.lang.String)>(v);
return;
}
public byte[] getJMSCorrelationIDAsBytes() throws javax.jms.JMSException
{
byte[] v;
org.apache.activemq.command.ActiveMQMessage v;
java.lang.String v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.String getCorrelationId()>();
v = staticinvoke <org.apache.activemq.command.ActiveMQMessage: byte[] encodeString(java.lang.String)>(v);
return v;
}
public void setJMSCorrelationIDAsBytes(byte[]) throws javax.jms.JMSException
{
byte[] v;
org.apache.activemq.command.ActiveMQMessage v;
java.lang.String v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: byte[];
v = staticinvoke <org.apache.activemq.command.ActiveMQMessage: java.lang.String decodeString(byte[])>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setCorrelationId(java.lang.String)>(v);
return;
}
public java.lang.String getJMSXMimeType()
{
org.apache.activemq.command.ActiveMQMessage v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
return "jms/message";
}
protected static java.lang.String decodeString(byte[]) throws javax.jms.JMSException
{
byte[] v;
java.lang.String v, v, v;
java.io.UnsupportedEncodingException v;
javax.jms.JMSException v;
v := @parameter: byte[];
label:
if v != null goto label;
label:
return null;
label:
v = new java.lang.String;
specialinvoke v.<java.lang.String: void <init>(byte[],java.lang.String)>(v, "UTF-8");
label:
return v;
label:
v := @caughtexception;
v = new javax.jms.JMSException;
v = virtualinvoke v.<java.io.UnsupportedEncodingException: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("Invalid UTF-8 encoding: \u0001");
specialinvoke v.<javax.jms.JMSException: void <init>(java.lang.String)>(v);
throw v;
catch java.io.UnsupportedEncodingException from label to label with label;
catch java.io.UnsupportedEncodingException from label to label with label;
}
protected static byte[] encodeString(java.lang.String) throws javax.jms.JMSException
{
byte[] v;
java.lang.String v, v, v;
java.io.UnsupportedEncodingException v;
javax.jms.JMSException v;
v := @parameter: java.lang.String;
label:
if v != null goto label;
label:
return null;
label:
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.lang.String)>("UTF-8");
label:
return v;
label:
v := @caughtexception;
v = new javax.jms.JMSException;
v = virtualinvoke v.<java.io.UnsupportedEncodingException: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("Invalid UTF-8 encoding: \u0001");
specialinvoke v.<javax.jms.JMSException: void <init>(java.lang.String)>(v);
throw v;
catch java.io.UnsupportedEncodingException from label to label with label;
catch java.io.UnsupportedEncodingException from label to label with label;
}
public javax.jms.Destination getJMSReplyTo()
{
org.apache.activemq.command.ActiveMQMessage v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.command.ActiveMQDestination getReplyTo()>();
return v;
}
public void setJMSReplyTo(javax.jms.Destination) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQMessage v;
javax.jms.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination transform(javax.jms.Destination)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setReplyTo(org.apache.activemq.command.ActiveMQDestination)>(v);
return;
}
public javax.jms.Destination getJMSDestination()
{
org.apache.activemq.command.ActiveMQMessage v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.command.ActiveMQDestination getDestination()>();
return v;
}
public void setJMSDestination(javax.jms.Destination) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQMessage v;
javax.jms.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination transform(javax.jms.Destination)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setDestination(org.apache.activemq.command.ActiveMQDestination)>(v);
return;
}
public int getJMSDeliveryMode()
{
org.apache.activemq.command.ActiveMQMessage v;
byte v;
boolean v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: boolean isPersistent()>();
if v == 0 goto label;
v = 2;
goto label;
label:
v = 1;
label:
return v;
}
public void setJMSDeliveryMode(int)
{
int v;
org.apache.activemq.command.ActiveMQMessage v;
boolean v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: int;
if v != 2 goto label;
v = 1;
goto label;
label:
v = 0;
label:
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setPersistent(boolean)>(v);
return;
}
public boolean getJMSRedelivered()
{
org.apache.activemq.command.ActiveMQMessage v;
boolean v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: boolean isRedelivered()>();
return v;
}
public void setJMSRedelivered(boolean)
{
org.apache.activemq.command.ActiveMQMessage v;
boolean v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: boolean;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setRedelivered(boolean)>(v);
return;
}
public java.lang.String getJMSType()
{
org.apache.activemq.command.ActiveMQMessage v;
java.lang.String v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.String getType()>();
return v;
}
public void setJMSType(java.lang.String)
{
org.apache.activemq.command.ActiveMQMessage v;
java.lang.String v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setType(java.lang.String)>(v);
return;
}
public long getJMSExpiration()
{
org.apache.activemq.command.ActiveMQMessage v;
long v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: long getExpiration()>();
return v;
}
public void setJMSExpiration(long)
{
org.apache.activemq.command.ActiveMQMessage v;
long v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: long;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setExpiration(long)>(v);
return;
}
public int getJMSPriority()
{
org.apache.activemq.command.ActiveMQMessage v;
byte v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: byte getPriority()>();
return v;
}
public void setJMSPriority(int)
{
int v;
org.apache.activemq.command.ActiveMQMessage v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: int;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setPriority(byte)>(v);
return;
}
public void clearProperties()
{
org.apache.activemq.command.ActiveMQMessage v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
specialinvoke v.<org.apache.activemq.command.Message: void clearProperties()>();
v.<org.apache.activemq.command.ActiveMQMessage: boolean readOnlyProperties> = 0;
return;
}
public boolean propertyExists(java.lang.String) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQMessage v;
java.io.IOException v;
javax.jms.JMSException v;
java.util.Map v;
java.lang.Object v;
java.lang.String v;
boolean v, v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.util.Map getProperties()>();
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.Object getObjectProperty(java.lang.String)>(v);
if v == null goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
label:
v := @caughtexception;
v = staticinvoke <org.apache.activemq.util.JMSExceptionSupport: javax.jms.JMSException create(java.lang.Exception)>(v);
throw v;
catch java.io.IOException from label to label with label;
}
public java.util.Enumeration getPropertyNames() throws javax.jms.JMSException
{
java.util.Enumeration v;
java.util.Set v;
org.apache.activemq.command.ActiveMQMessage v;
java.io.IOException v;
javax.jms.JMSException v;
java.util.Vector v;
java.util.Map v;
int v;
java.lang.String v, v, v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
label:
v = new java.util.Vector;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.util.Map getProperties()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
specialinvoke v.<java.util.Vector: void <init>(java.util.Collection)>(v);
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: int getRedeliveryCounter()>();
if v == 0 goto label;
virtualinvoke v.<java.util.Vector: boolean add(java.lang.Object)>("JMSXDeliveryCount");
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.String getGroupID()>();
if v == null goto label;
virtualinvoke v.<java.util.Vector: boolean add(java.lang.Object)>("JMSXGroupID");
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.String getGroupID()>();
if v == null goto label;
virtualinvoke v.<java.util.Vector: boolean add(java.lang.Object)>("JMSXGroupSeq");
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.String getUserID()>();
if v == null goto label;
virtualinvoke v.<java.util.Vector: boolean add(java.lang.Object)>("JMSXUserID");
label:
v = virtualinvoke v.<java.util.Vector: java.util.Enumeration elements()>();
label:
return v;
label:
v := @caughtexception;
v = staticinvoke <org.apache.activemq.util.JMSExceptionSupport: javax.jms.JMSException create(java.lang.Exception)>(v);
throw v;
catch java.io.IOException from label to label with label;
}
public java.util.Enumeration getAllPropertyNames() throws javax.jms.JMSException
{
java.util.Enumeration v;
java.util.Set v, v;
org.apache.activemq.command.ActiveMQMessage v;
java.io.IOException v;
javax.jms.JMSException v;
java.util.Vector v;
java.util.Map v, v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
label:
v = new java.util.Vector;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.util.Map getProperties()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
specialinvoke v.<java.util.Vector: void <init>(java.util.Collection)>(v);
v = <org.apache.activemq.command.ActiveMQMessage: java.util.Map JMS_PROPERTY_SETERS>;
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
virtualinvoke v.<java.util.Vector: boolean addAll(java.util.Collection)>(v);
v = virtualinvoke v.<java.util.Vector: java.util.Enumeration elements()>();
label:
return v;
label:
v := @caughtexception;
v = staticinvoke <org.apache.activemq.util.JMSExceptionSupport: javax.jms.JMSException create(java.lang.Exception)>(v);
throw v;
catch java.io.IOException from label to label with label;
}
public void setObjectProperty(java.lang.String, java.lang.Object) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQMessage v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setObjectProperty(java.lang.String,java.lang.Object,boolean)>(v, v, 1);
return;
}
public void setObjectProperty(java.lang.String, java.lang.Object, boolean) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQMessage v;
java.io.IOException v;
java.lang.IllegalArgumentException v;
javax.jms.JMSException v;
java.util.Map v;
java.lang.Object v, v, v;
java.lang.String v;
boolean v, v, v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
v := @parameter: boolean;
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void checkReadOnlyProperties()>();
label:
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("");
if v == 0 goto label;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Property name cannot be empty or null");
throw v;
label:
v = v instanceof org.fusesource.hawtbuf.UTF8Buffer;
if v == 0 goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
label:
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void checkValidObject(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.Object convertScheduled(java.lang.String,java.lang.Object)>(v, v);
v = <org.apache.activemq.command.ActiveMQMessage: java.util.Map JMS_PROPERTY_SETERS>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
if v == null goto label;
interfaceinvoke v.<org.apache.activemq.command.ActiveMQMessage$PropertySetter: void set(org.apache.activemq.command.Message,java.lang.Object)>(v, v);
goto label;
label:
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setProperty(java.lang.String,java.lang.Object)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <org.apache.activemq.util.JMSExceptionSupport: javax.jms.JMSException create(java.lang.Exception)>(v);
throw v;
label:
return;
catch java.io.IOException from label to label with label;
}
public void setProperties(java.util.Map) throws javax.jms.JMSException
{
java.util.Iterator v;
java.util.Set v;
org.apache.activemq.command.ActiveMQMessage v;
java.util.Map v;
java.lang.Object v, v, v;
boolean v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.util.Map;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setObjectProperty(java.lang.String,java.lang.Object)>(v, v);
goto label;
label:
return;
}
protected void checkValidObject(java.lang.Object) throws javax.jms.MessageFormatException
{
org.apache.activemq.command.ActiveMQMessage v;
java.lang.String v, v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.ActiveMQConnection v;
javax.jms.MessageFormatException v, v;
java.lang.Class v, v;
java.lang.Object v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.Object;
v = v instanceof java.lang.Boolean;
if v != 0 goto label;
v = v instanceof java.lang.Byte;
if v != 0 goto label;
v = v instanceof java.lang.Short;
if v != 0 goto label;
v = v instanceof java.lang.Integer;
if v != 0 goto label;
v = v instanceof java.lang.Long;
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
if v != 0 goto label;
v = v instanceof java.lang.Float;
if v != 0 goto label;
v = v instanceof java.lang.Double;
if v != 0 goto label;
v = v instanceof java.lang.Character;
if v != 0 goto label;
v = v instanceof java.lang.String;
if v != 0 goto label;
if v != null goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
if v != 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.ActiveMQConnection getConnection()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.ActiveMQConnection: boolean isNestedMapAndListEnabled()>();
if v == 0 goto label;
label:
v = v instanceof java.util.Map;
if v != 0 goto label;
v = v instanceof java.util.List;
if v != 0 goto label;
v = new javax.jms.MessageFormatException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Object,java.lang.Class)>(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[])>("Only objectified primitive objects, String, Map and List types are allowed but was: \u type: \u0001");
specialinvoke v.<javax.jms.MessageFormatException: void <init>(java.lang.String)>(v);
throw v;
label:
v = new javax.jms.MessageFormatException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Object,java.lang.Class)>(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[])>("Only objectified primitive objects and String types are allowed but was: \u type: \u0001");
specialinvoke v.<javax.jms.MessageFormatException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
protected java.lang.Object convertScheduled(java.lang.String, java.lang.Object) throws javax.jms.MessageFormatException
{
org.apache.activemq.command.ActiveMQMessage v;
long v, v;
byte v, v;
int v;
java.lang.String v, v, v, v, v, v, v, v, v;
boolean v, v, v, v;
javax.jms.MessageFormatException v, v, v;
java.lang.Object v, v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
v = v;
v = "AMQ_SCHEDULED_DELAY";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = staticinvoke <org.apache.activemq.util.TypeConversionSupport: java.lang.Object convert(java.lang.Object,java.lang.Class)>(v, class "Ljava/lang/Long;");
if v == null goto label;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v cmp 0L;
if v >= 0 goto label;
v = new javax.jms.MessageFormatException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u must not be a negative value");
specialinvoke v.<javax.jms.MessageFormatException: void <init>(java.lang.String)>(v);
throw v;
label:
v = "AMQ_SCHEDULED_PERIOD";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = staticinvoke <org.apache.activemq.util.TypeConversionSupport: java.lang.Object convert(java.lang.Object,java.lang.Class)>(v, class "Ljava/lang/Long;");
if v == null goto label;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v cmp 0L;
if v >= 0 goto label;
v = new javax.jms.MessageFormatException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u must not be a negative value");
specialinvoke v.<javax.jms.MessageFormatException: void <init>(java.lang.String)>(v);
throw v;
label:
v = "AMQ_SCHEDULED_REPEAT";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = staticinvoke <org.apache.activemq.util.TypeConversionSupport: java.lang.Object convert(java.lang.Object,java.lang.Class)>(v, class "Ljava/lang/Integer;");
if v == null goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v >= 0 goto label;
v = new javax.jms.MessageFormatException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u must not be a negative value");
specialinvoke v.<javax.jms.MessageFormatException: void <init>(java.lang.String)>(v);
throw v;
label:
v = "AMQ_SCHEDULED_CRON";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
staticinvoke <org.apache.activemq.broker.scheduler.CronParser: void validate(java.lang.String)>(v);
label:
return v;
}
public java.lang.Object getObjectProperty(java.lang.String) throws javax.jms.JMSException
{
org.apache.activemq.filter.PropertyExpression v;
org.apache.activemq.command.ActiveMQMessage v;
java.lang.Object v;
java.lang.String v;
java.lang.NullPointerException v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
if v != null goto label;
v = new java.lang.NullPointerException;
specialinvoke v.<java.lang.NullPointerException: void <init>(java.lang.String)>("Property name cannot be null");
throw v;
label:
v = new org.apache.activemq.filter.PropertyExpression;
specialinvoke v.<org.apache.activemq.filter.PropertyExpression: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.filter.PropertyExpression: java.lang.Object evaluate(org.apache.activemq.command.Message)>(v);
return v;
}
public boolean getBooleanProperty(java.lang.String) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQMessage v;
javax.jms.MessageFormatException v;
java.lang.Class v;
java.lang.Object v, v;
java.lang.String v, v, v;
boolean v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.Object getObjectProperty(java.lang.String)>(v);
if v != null goto label;
return 0;
label:
v = staticinvoke <org.apache.activemq.util.TypeConversionSupport: java.lang.Object convert(java.lang.Object,java.lang.Class)>(v, class "Ljava/lang/Boolean;");
if v != null goto label;
v = new javax.jms.MessageFormatException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("Property \u was a \u and cannot be read as a boolean");
specialinvoke v.<javax.jms.MessageFormatException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
return v;
}
public byte getByteProperty(java.lang.String) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQMessage v;
java.lang.NumberFormatException v;
byte v;
javax.jms.MessageFormatException v;
java.lang.Class v;
java.lang.Object v, v;
java.lang.String v, v, v, v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.Object getObjectProperty(java.lang.String)>(v);
if v != null goto label;
v = new java.lang.NumberFormatException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("property \u was null");
specialinvoke v.<java.lang.NumberFormatException: void <init>(java.lang.String)>(v);
throw v;
label:
v = staticinvoke <org.apache.activemq.util.TypeConversionSupport: java.lang.Object convert(java.lang.Object,java.lang.Class)>(v, class "Ljava/lang/Byte;");
if v != null goto label;
v = new javax.jms.MessageFormatException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("Property \u was a \u and cannot be read as a byte");
specialinvoke v.<javax.jms.MessageFormatException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<java.lang.Byte: byte byteValue()>();
return v;
}
public short getShortProperty(java.lang.String) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQMessage v;
java.lang.NumberFormatException v;
short v;
javax.jms.MessageFormatException v;
java.lang.Class v;
java.lang.Object v, v;
java.lang.String v, v, v, v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.Object getObjectProperty(java.lang.String)>(v);
if v != null goto label;
v = new java.lang.NumberFormatException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("property \u was null");
specialinvoke v.<java.lang.NumberFormatException: void <init>(java.lang.String)>(v);
throw v;
label:
v = staticinvoke <org.apache.activemq.util.TypeConversionSupport: java.lang.Object convert(java.lang.Object,java.lang.Class)>(v, class "Ljava/lang/Short;");
if v != null goto label;
v = new javax.jms.MessageFormatException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("Property \u was a \u and cannot be read as a short");
specialinvoke v.<javax.jms.MessageFormatException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<java.lang.Short: short shortValue()>();
return v;
}
public int getIntProperty(java.lang.String) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQMessage v;
java.lang.NumberFormatException v;
javax.jms.MessageFormatException v;
int v;
java.lang.Class v;
java.lang.Object v, v;
java.lang.String v, v, v, v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.Object getObjectProperty(java.lang.String)>(v);
if v != null goto label;
v = new java.lang.NumberFormatException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("property \u was null");
specialinvoke v.<java.lang.NumberFormatException: void <init>(java.lang.String)>(v);
throw v;
label:
v = staticinvoke <org.apache.activemq.util.TypeConversionSupport: java.lang.Object convert(java.lang.Object,java.lang.Class)>(v, class "Ljava/lang/Integer;");
if v != null goto label;
v = new javax.jms.MessageFormatException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("Property \u was a \u and cannot be read as an integer");
specialinvoke v.<javax.jms.MessageFormatException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
return v;
}
public long getLongProperty(java.lang.String) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQMessage v;
java.lang.NumberFormatException v;
long v;
javax.jms.MessageFormatException v;
java.lang.Class v;
java.lang.Object v, v;
java.lang.String v, v, v, v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.Object getObjectProperty(java.lang.String)>(v);
if v != null goto label;
v = new java.lang.NumberFormatException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("property \u was null");
specialinvoke v.<java.lang.NumberFormatException: void <init>(java.lang.String)>(v);
throw v;
label:
v = staticinvoke <org.apache.activemq.util.TypeConversionSupport: java.lang.Object convert(java.lang.Object,java.lang.Class)>(v, class "Ljava/lang/Long;");
if v != null goto label;
v = new javax.jms.MessageFormatException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("Property \u was a \u and cannot be read as a long");
specialinvoke v.<javax.jms.MessageFormatException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<java.lang.Long: long longValue()>();
return v;
}
public float getFloatProperty(java.lang.String) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQMessage v;
java.lang.NullPointerException v;
javax.jms.MessageFormatException v;
float v;
java.lang.Class v;
java.lang.Object v, v;
java.lang.String v, v, v, v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.Object getObjectProperty(java.lang.String)>(v);
if v != null goto label;
v = new java.lang.NullPointerException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("property \u was null");
specialinvoke v.<java.lang.NullPointerException: void <init>(java.lang.String)>(v);
throw v;
label:
v = staticinvoke <org.apache.activemq.util.TypeConversionSupport: java.lang.Object convert(java.lang.Object,java.lang.Class)>(v, class "Ljava/lang/Float;");
if v != null goto label;
v = new javax.jms.MessageFormatException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("Property \u was a \u and cannot be read as a float");
specialinvoke v.<javax.jms.MessageFormatException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<java.lang.Float: float floatValue()>();
return v;
}
public double getDoubleProperty(java.lang.String) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQMessage v;
java.lang.NullPointerException v;
javax.jms.MessageFormatException v;
java.lang.Class v;
java.lang.Object v, v;
java.lang.String v, v, v, v;
double v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.Object getObjectProperty(java.lang.String)>(v);
if v != null goto label;
v = new java.lang.NullPointerException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("property \u was null");
specialinvoke v.<java.lang.NullPointerException: void <init>(java.lang.String)>(v);
throw v;
label:
v = staticinvoke <org.apache.activemq.util.TypeConversionSupport: java.lang.Object convert(java.lang.Object,java.lang.Class)>(v, class "Ljava/lang/Double;");
if v != null goto label;
v = new javax.jms.MessageFormatException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("Property \u was a \u and cannot be read as a double");
specialinvoke v.<javax.jms.MessageFormatException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<java.lang.Double: double doubleValue()>();
return v;
}
public java.lang.String getStringProperty(java.lang.String) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQMessage v;
javax.jms.MessageFormatException v;
java.lang.Class v;
java.lang.Object v, v;
java.lang.String v, v, v, v;
boolean v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v = "JMSXUserID";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.String getUserID()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.Object getObjectProperty(java.lang.String)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.Object getObjectProperty(java.lang.String)>(v);
label:
if v != null goto label;
return null;
label:
v = staticinvoke <org.apache.activemq.util.TypeConversionSupport: java.lang.Object convert(java.lang.Object,java.lang.Class)>(v, class "Ljava/lang/String;");
if v != null goto label;
v = new javax.jms.MessageFormatException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("Property \u was a \u and cannot be read as a String");
specialinvoke v.<javax.jms.MessageFormatException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public void setBooleanProperty(java.lang.String, boolean) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQMessage v;
java.lang.String v;
boolean v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v := @parameter: boolean;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setBooleanProperty(java.lang.String,boolean,boolean)>(v, v, 1);
return;
}
public void setBooleanProperty(java.lang.String, boolean, boolean) throws javax.jms.JMSException
{
java.lang.Boolean v;
org.apache.activemq.command.ActiveMQMessage v;
java.lang.String v;
boolean v, v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: boolean;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setObjectProperty(java.lang.String,java.lang.Object,boolean)>(v, v, v);
return;
}
public void setByteProperty(java.lang.String, byte) throws javax.jms.JMSException
{
byte v;
org.apache.activemq.command.ActiveMQMessage v;
java.lang.String v;
java.lang.Byte v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v := @parameter: byte;
v = staticinvoke <java.lang.Byte: java.lang.Byte valueOf(byte)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setObjectProperty(java.lang.String,java.lang.Object)>(v, v);
return;
}
public void setShortProperty(java.lang.String, short) throws javax.jms.JMSException
{
short v;
java.lang.Short v;
org.apache.activemq.command.ActiveMQMessage v;
java.lang.String v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v := @parameter: short;
v = staticinvoke <java.lang.Short: java.lang.Short valueOf(short)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setObjectProperty(java.lang.String,java.lang.Object)>(v, v);
return;
}
public void setIntProperty(java.lang.String, int) throws javax.jms.JMSException
{
int v;
org.apache.activemq.command.ActiveMQMessage v;
java.lang.String v;
java.lang.Integer v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v := @parameter: int;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setObjectProperty(java.lang.String,java.lang.Object)>(v, v);
return;
}
public void setLongProperty(java.lang.String, long) throws javax.jms.JMSException
{
java.lang.Long v;
org.apache.activemq.command.ActiveMQMessage v;
long v;
java.lang.String v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v := @parameter: long;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setObjectProperty(java.lang.String,java.lang.Object)>(v, v);
return;
}
public void setFloatProperty(java.lang.String, float) throws javax.jms.JMSException
{
java.lang.Float v;
float v;
org.apache.activemq.command.ActiveMQMessage v;
java.lang.String v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v := @parameter: float;
v = new java.lang.Float;
specialinvoke v.<java.lang.Float: void <init>(float)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setObjectProperty(java.lang.String,java.lang.Object)>(v, v);
return;
}
public void setDoubleProperty(java.lang.String, double) throws javax.jms.JMSException
{
java.lang.Double v;
org.apache.activemq.command.ActiveMQMessage v;
java.lang.String v;
double v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v := @parameter: double;
v = new java.lang.Double;
specialinvoke v.<java.lang.Double: void <init>(double)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setObjectProperty(java.lang.String,java.lang.Object)>(v, v);
return;
}
public void setStringProperty(java.lang.String, java.lang.String) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQMessage v;
java.lang.String v, v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setObjectProperty(java.lang.String,java.lang.Object)>(v, v);
return;
}
protected void checkReadOnlyProperties() throws javax.jms.MessageNotWriteableException
{
org.apache.activemq.command.ActiveMQMessage v;
javax.jms.MessageNotWriteableException v;
boolean v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v = v.<org.apache.activemq.command.ActiveMQMessage: boolean readOnlyProperties>;
if v == 0 goto label;
v = new javax.jms.MessageNotWriteableException;
specialinvoke v.<javax.jms.MessageNotWriteableException: void <init>(java.lang.String)>("Message properties are read-only");
throw v;
label:
return;
}
protected void checkReadOnlyBody() throws javax.jms.MessageNotWriteableException
{
org.apache.activemq.command.ActiveMQMessage v;
javax.jms.MessageNotWriteableException v;
boolean v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v = v.<org.apache.activemq.command.ActiveMQMessage: boolean readOnlyBody>;
if v == 0 goto label;
v = new javax.jms.MessageNotWriteableException;
specialinvoke v.<javax.jms.MessageNotWriteableException: void <init>(java.lang.String)>("Message body is read-only");
throw v;
label:
return;
}
public org.apache.activemq.util.Callback getAcknowledgeCallback()
{
org.apache.activemq.command.ActiveMQMessage v;
org.apache.activemq.util.Callback v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v = v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.util.Callback acknowledgeCallback>;
return v;
}
public void setAcknowledgeCallback(org.apache.activemq.util.Callback)
{
org.apache.activemq.command.ActiveMQMessage v;
org.apache.activemq.util.Callback v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: org.apache.activemq.util.Callback;
v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.util.Callback acknowledgeCallback> = v;
return;
}
public void onSend() throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQMessage v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setReadOnlyBody(boolean)>(1);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setReadOnlyProperties(boolean)>(1);
return;
}
public org.apache.activemq.command.Response visit(org.apache.activemq.state.CommandVisitor) throws java.lang.Exception
{
org.apache.activemq.command.Response v;
org.apache.activemq.command.ActiveMQMessage v;
org.apache.activemq.state.CommandVisitor v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: org.apache.activemq.state.CommandVisitor;
v = interfaceinvoke v.<org.apache.activemq.state.CommandVisitor: org.apache.activemq.command.Response processMessage(org.apache.activemq.command.Message)>(v);
return v;
}
public void storeContent()
{
org.apache.activemq.command.ActiveMQMessage v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
return;
}
public void storeContentAndClear()
{
org.apache.activemq.command.ActiveMQMessage v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void storeContent()>();
return;
}
protected boolean isContentMarshalled()
{
org.apache.activemq.command.ActiveMQMessage v;
v := @this: org.apache.activemq.command.ActiveMQMessage;
return 1;
}
static void <clinit>()
{
org.apache.activemq.command.ActiveMQMessage$8 v;
org.apache.activemq.command.ActiveMQMessage$9 v;
java.util.HashMap v;
org.apache.activemq.command.ActiveMQMessage$10 v;
java.util.Map v, v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.command.ActiveMQMessage$11 v;
org.apache.activemq.command.ActiveMQMessage$4 v;
org.apache.activemq.command.ActiveMQMessage$5 v;
org.apache.activemq.command.ActiveMQMessage$6 v;
org.apache.activemq.command.ActiveMQMessage$7 v;
org.apache.activemq.command.ActiveMQMessage$1 v;
org.apache.activemq.command.ActiveMQMessage$2 v;
org.apache.activemq.command.ActiveMQMessage$3 v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
<org.apache.activemq.command.ActiveMQMessage: java.util.Map JMS_PROPERTY_SETERS> = v;
v = <org.apache.activemq.command.ActiveMQMessage: java.util.Map JMS_PROPERTY_SETERS>;
v = new org.apache.activemq.command.ActiveMQMessage$1;
specialinvoke v.<org.apache.activemq.command.ActiveMQMessage$1: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("JMSXDeliveryCount", v);
v = <org.apache.activemq.command.ActiveMQMessage: java.util.Map JMS_PROPERTY_SETERS>;
v = new org.apache.activemq.command.ActiveMQMessage$2;
specialinvoke v.<org.apache.activemq.command.ActiveMQMessage$2: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("JMSXGroupID", v);
v = <org.apache.activemq.command.ActiveMQMessage: java.util.Map JMS_PROPERTY_SETERS>;
v = new org.apache.activemq.command.ActiveMQMessage$3;
specialinvoke v.<org.apache.activemq.command.ActiveMQMessage$3: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("JMSXGroupSeq", v);
v = <org.apache.activemq.command.ActiveMQMessage: java.util.Map JMS_PROPERTY_SETERS>;
v = new org.apache.activemq.command.ActiveMQMessage$4;
specialinvoke v.<org.apache.activemq.command.ActiveMQMessage$4: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("JMSCorrelationID", v);
v = <org.apache.activemq.command.ActiveMQMessage: java.util.Map JMS_PROPERTY_SETERS>;
v = new org.apache.activemq.command.ActiveMQMessage$5;
specialinvoke v.<org.apache.activemq.command.ActiveMQMessage$5: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("JMSDeliveryMode", v);
v = <org.apache.activemq.command.ActiveMQMessage: java.util.Map JMS_PROPERTY_SETERS>;
v = new org.apache.activemq.command.ActiveMQMessage$6;
specialinvoke v.<org.apache.activemq.command.ActiveMQMessage$6: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("JMSExpiration", v);
v = <org.apache.activemq.command.ActiveMQMessage: java.util.Map JMS_PROPERTY_SETERS>;
v = new org.apache.activemq.command.ActiveMQMessage$7;
specialinvoke v.<org.apache.activemq.command.ActiveMQMessage$7: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("JMSPriority", v);
v = <org.apache.activemq.command.ActiveMQMessage: java.util.Map JMS_PROPERTY_SETERS>;
v = new org.apache.activemq.command.ActiveMQMessage$8;
specialinvoke v.<org.apache.activemq.command.ActiveMQMessage$8: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("JMSRedelivered", v);
v = <org.apache.activemq.command.ActiveMQMessage: java.util.Map JMS_PROPERTY_SETERS>;
v = new org.apache.activemq.command.ActiveMQMessage$9;
specialinvoke v.<org.apache.activemq.command.ActiveMQMessage$9: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("JMSReplyTo", v);
v = <org.apache.activemq.command.ActiveMQMessage: java.util.Map JMS_PROPERTY_SETERS>;
v = new org.apache.activemq.command.ActiveMQMessage$10;
specialinvoke v.<org.apache.activemq.command.ActiveMQMessage$10: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("JMSTimestamp", v);
v = <org.apache.activemq.command.ActiveMQMessage: java.util.Map JMS_PROPERTY_SETERS>;
v = new org.apache.activemq.command.ActiveMQMessage$11;
specialinvoke v.<org.apache.activemq.command.ActiveMQMessage$11: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("JMSType", v);
return;
}
}