public abstract class org.apache.activemq.transport.amqp.message.InboundTransformer extends java.lang.Object
{
public static final java.lang.String TRANSFORMER_NATIVE;
public static final java.lang.String TRANSFORMER_RAW;
public static final java.lang.String TRANSFORMER_JMS;
public void <init>()
{
org.apache.activemq.transport.amqp.message.InboundTransformer v;
v := @this: org.apache.activemq.transport.amqp.message.InboundTransformer;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public abstract java.lang.String getTransformerName();
public abstract org.apache.activemq.transport.amqp.message.InboundTransformer getFallbackTransformer();
public final org.apache.activemq.command.ActiveMQMessage transform(org.apache.activemq.transport.amqp.message.EncodedMessage) throws java.lang.Exception
{
org.apache.activemq.transport.amqp.message.InboundTransformer v, v;
org.apache.activemq.command.ActiveMQMessage v;
org.apache.activemq.transport.amqp.AmqpProtocolException v;
java.lang.Exception v;
org.apache.activemq.transport.amqp.message.EncodedMessage v;
v := @this: org.apache.activemq.transport.amqp.message.InboundTransformer;
v := @parameter: org.apache.activemq.transport.amqp.message.EncodedMessage;
v = v;
v = null;
label:
if v == null goto label;
label:
v = virtualinvoke v.<org.apache.activemq.transport.amqp.message.InboundTransformer: org.apache.activemq.command.ActiveMQMessage doTransform(org.apache.activemq.transport.amqp.message.EncodedMessage)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.activemq.transport.amqp.message.InboundTransformer: org.apache.activemq.transport.amqp.message.InboundTransformer getFallbackTransformer()>();
goto label;
label:
if v != null goto label;
v = new org.apache.activemq.transport.amqp.AmqpProtocolException;
specialinvoke v.<org.apache.activemq.transport.amqp.AmqpProtocolException: void <init>(java.lang.String,boolean)>("Failed to transform incoming delivery, skipping.", 0);
throw v;
label:
return v;
catch java.lang.Exception from label to label with label;
}
protected abstract org.apache.activemq.command.ActiveMQMessage doTransform(org.apache.activemq.transport.amqp.message.EncodedMessage) throws java.lang.Exception;
protected void populateMessage(org.apache.activemq.command.ActiveMQMessage, org.apache.qpid.proton.message.Message) throws java.lang.Exception
{
byte[] v;
org.apache.activemq.transport.amqp.message.InboundTransformer v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v, v, v, v, v;
byte v, v, v, v, v;
java.util.Map v, v, v;
java.util.Set v, v, v;
org.apache.qpid.proton.amqp.messaging.MessageAnnotations v;
long v, v, v, v, v, v, v, v, v, v, v;
org.apache.qpid.proton.amqp.Symbol v, v, v, v;
org.apache.qpid.proton.amqp.UnsignedByte v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.qpid.proton.amqp.messaging.Header v;
java.util.Date v, v, v, v;
org.apache.activemq.command.ActiveMQMessage v;
org.apache.qpid.proton.amqp.Binary v;
boolean v, v, v, v, v, v, v, v, v, v;
org.apache.qpid.proton.amqp.messaging.Footer v;
org.apache.activemq.command.ActiveMQDestination v, v;
java.nio.charset.Charset v;
int v, v, v, v, v, v;
java.lang.Boolean v, v, v, v;
org.apache.qpid.proton.message.Message v;
java.util.Iterator v, v, v;
org.apache.qpid.proton.amqp.messaging.Properties v;
org.apache.qpid.proton.amqp.messaging.ApplicationProperties v;
org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper v, v;
java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.activemq.transport.amqp.message.InboundTransformer;
v := @parameter: org.apache.activemq.command.ActiveMQMessage;
v := @parameter: org.apache.qpid.proton.message.Message;
v = interfaceinvoke v.<org.apache.qpid.proton.message.Message: org.apache.qpid.proton.amqp.messaging.Header getHeader()>();
if v == null goto label;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setBooleanProperty(java.lang.String,boolean)>("JMS_AMQP_HEADER", 1);
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: java.lang.Boolean getDurable()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: java.lang.Boolean getDurable()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setPersistent(boolean)>(v);
goto label;
label:
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setPersistent(boolean)>(0);
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: org.apache.qpid.proton.amqp.UnsignedByte getPriority()>();
if v == null goto label;
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: int intValue()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setJMSPriority(int)>(v);
goto label;
label:
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setPriority(byte)>(4);
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: java.lang.Boolean getFirstAcquirer()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: java.lang.Boolean getFirstAcquirer()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setBooleanProperty(java.lang.String,boolean)>("JMS_AMQP_FirstAcquirer", v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: org.apache.qpid.proton.amqp.UnsignedInteger getDeliveryCount()>();
if v == null goto label;
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: int intValue()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setRedeliveryCounter(int)>(v);
goto label;
label:
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setPriority(byte)>(4);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setPersistent(boolean)>(0);
label:
v = interfaceinvoke v.<org.apache.qpid.proton.message.Message: org.apache.qpid.proton.amqp.messaging.MessageAnnotations getMessageAnnotations()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.MessageAnnotations: java.util.Map getValue()>();
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 = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = "x-opt-delivery-time";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
if v == null goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<java.lang.Number: long longValue()>();
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v - v;
v = v cmp 0L;
if v <= 0 goto label;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setLongProperty(java.lang.String,long)>("AMQ_SCHEDULED_DELAY", v);
goto label;
label:
v = "x-opt-delivery-delay";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
if v == null goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<java.lang.Number: long longValue()>();
v = v cmp 0L;
if v <= 0 goto label;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setLongProperty(java.lang.String,long)>("AMQ_SCHEDULED_DELAY", v);
goto label;
label:
v = "x-opt-delivery-repeat";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
if v == null goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<java.lang.Number: int intValue()>();
if v <= 0 goto label;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setIntProperty(java.lang.String,int)>("AMQ_SCHEDULED_REPEAT", v);
goto label;
label:
v = "x-opt-delivery-period";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
if v == null goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<java.lang.Number: long longValue()>();
v = v cmp 0L;
if v <= 0 goto label;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setLongProperty(java.lang.String,long)>("AMQ_SCHEDULED_PERIOD", v);
goto label;
label:
v = "x-opt-delivery-cron";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
if v == null goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
if v == null goto label;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setStringProperty(java.lang.String,java.lang.String)>("AMQ_SCHEDULED_CRON", v);
label:
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[])>("JMS_AMQP_MA_\u0001");
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
specialinvoke v.<org.apache.activemq.transport.amqp.message.InboundTransformer: void setProperty(javax.jms.Message,java.lang.String,java.lang.Object)>(v, v, v);
goto label;
label:
v = interfaceinvoke v.<org.apache.qpid.proton.message.Message: org.apache.qpid.proton.amqp.messaging.ApplicationProperties getApplicationProperties()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.ApplicationProperties: java.util.Map getValue()>();
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()>();
specialinvoke v.<org.apache.activemq.transport.amqp.message.InboundTransformer: void setProperty(javax.jms.Message,java.lang.String,java.lang.Object)>(v, v, v);
goto label;
label:
v = interfaceinvoke v.<org.apache.qpid.proton.message.Message: org.apache.qpid.proton.amqp.messaging.Properties getProperties()>();
if v == null goto label;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setBooleanProperty(java.lang.String,boolean)>("JMS_AMQP_PROPERTIES", 1);
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.Object getMessageId()>();
if v == null goto label;
v = <org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper: org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper INSTANCE>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.Object getMessageId()>();
v = virtualinvoke v.<org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper: java.lang.String toBaseMessageIdString(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setJMSMessageID(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: org.apache.qpid.proton.amqp.Binary getUserId()>();
if v == null goto label;
v = new java.lang.String;
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()>();
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
specialinvoke v.<java.lang.String: void <init>(byte[],int,int,java.nio.charset.Charset)>(v, v, v, v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setUserID(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.String getTo()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.String getTo()>();
v = staticinvoke <org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination createDestination(java.lang.String,byte)>(v, 1);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setDestination(org.apache.activemq.command.ActiveMQDestination)>(v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.String getSubject()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.String getSubject()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setType(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.String getReplyTo()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.String getReplyTo()>();
v = staticinvoke <org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination createDestination(java.lang.String,byte)>(v, 1);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setReplyTo(org.apache.activemq.command.ActiveMQDestination)>(v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.Object getCorrelationId()>();
if v == null goto label;
v = <org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper: org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper INSTANCE>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.Object getCorrelationId()>();
v = virtualinvoke v.<org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper: java.lang.String toBaseMessageIdString(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setCorrelationId(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: org.apache.qpid.proton.amqp.Symbol getContentType()>();
if v == null goto label;
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()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setStringProperty(java.lang.String,java.lang.String)>("JMS_AMQP_ContentType", v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: org.apache.qpid.proton.amqp.Symbol getContentEncoding()>();
if v == null goto label;
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()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setStringProperty(java.lang.String,java.lang.String)>("JMS_AMQP_ContentEncoding", v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.util.Date getCreationTime()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.util.Date getCreationTime()>();
v = virtualinvoke v.<java.util.Date: long getTime()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setTimestamp(long)>(v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.String getGroupId()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.String getGroupId()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setGroupID(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: org.apache.qpid.proton.amqp.UnsignedInteger getGroupSequence()>();
if v == null goto label;
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()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setGroupSequence(int)>(v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.String getReplyToGroupId()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.lang.String getReplyToGroupId()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setStringProperty(java.lang.String,java.lang.String)>("JMS_AMQP_ReplyToGroupID", v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.util.Date getAbsoluteExpiryTime()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: java.util.Date getAbsoluteExpiryTime()>();
v = virtualinvoke v.<java.util.Date: long getTime()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setExpiration(long)>(v);
label:
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: long getJMSExpiration()>();
v = v cmp 0L;
if v != 0 goto label;
v = 0L;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: org.apache.qpid.proton.amqp.UnsignedInteger getTtl()>();
if v == null goto label;
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:
v = v cmp 0L;
if v == 0 goto label;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v + v;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setExpiration(long)>(v);
label:
v = interfaceinvoke v.<org.apache.qpid.proton.message.Message: org.apache.qpid.proton.amqp.messaging.Footer getFooter()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Footer: java.util.Map getValue()>();
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 = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
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[])>("JMS_AMQP_FT_\u0001");
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
specialinvoke v.<org.apache.activemq.transport.amqp.message.InboundTransformer: void setProperty(javax.jms.Message,java.lang.String,java.lang.Object)>(v, v, v);
goto label;
label:
return;
}
private void setProperty(javax.jms.Message, java.lang.String, java.lang.Object) throws javax.jms.JMSException
{
org.apache.activemq.transport.amqp.message.InboundTransformer v;
long v, v;
short v;
byte v, v;
int v, v, v;
java.lang.String v, v, v;
javax.jms.Message v;
boolean v, v, v, v, v, v, v, v, v;
double v, v;
float v;
java.lang.Object v;
v := @this: org.apache.activemq.transport.amqp.message.InboundTransformer;
v := @parameter: javax.jms.Message;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.qpid.proton.amqp.UnsignedLong;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedLong: long longValue()>();
interfaceinvoke v.<javax.jms.Message: void setLongProperty(java.lang.String,long)>(v, v);
goto label;
label:
v = v instanceof org.apache.qpid.proton.amqp.UnsignedInteger;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: long longValue()>();
v = -2147483648L cmp v;
if v > 0 goto label;
v = v cmp 2147483647L;
if v > 0 goto label;
interfaceinvoke v.<javax.jms.Message: void setIntProperty(java.lang.String,int)>(v, v);
goto label;
label:
interfaceinvoke v.<javax.jms.Message: void setLongProperty(java.lang.String,long)>(v, v);
goto label;
label:
v = v instanceof org.apache.qpid.proton.amqp.UnsignedShort;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedShort: int intValue()>();
v = (int) -32768;
if v > v goto label;
if v > 32767 goto label;
interfaceinvoke v.<javax.jms.Message: void setShortProperty(java.lang.String,short)>(v, v);
goto label;
label:
interfaceinvoke v.<javax.jms.Message: void setIntProperty(java.lang.String,int)>(v, v);
goto label;
label:
v = v instanceof org.apache.qpid.proton.amqp.UnsignedByte;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedByte: short shortValue()>();
v = (int) -128;
if v > v goto label;
if v > 127 goto label;
interfaceinvoke v.<javax.jms.Message: void setByteProperty(java.lang.String,byte)>(v, v);
goto label;
label:
interfaceinvoke v.<javax.jms.Message: void setShortProperty(java.lang.String,short)>(v, v);
goto label;
label:
v = v instanceof org.apache.qpid.proton.amqp.Symbol;
if v == 0 goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
interfaceinvoke v.<javax.jms.Message: void setStringProperty(java.lang.String,java.lang.String)>(v, v);
goto label;
label:
v = v instanceof org.apache.qpid.proton.amqp.Decimal;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Decimal128: double doubleValue()>();
interfaceinvoke v.<javax.jms.Message: void setDoubleProperty(java.lang.String,double)>(v, v);
goto label;
label:
v = v instanceof org.apache.qpid.proton.amqp.Decimal;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Decimal64: double doubleValue()>();
interfaceinvoke v.<javax.jms.Message: void setDoubleProperty(java.lang.String,double)>(v, v);
goto label;
label:
v = v instanceof org.apache.qpid.proton.amqp.Decimal;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Decimal32: float floatValue()>();
interfaceinvoke v.<javax.jms.Message: void setFloatProperty(java.lang.String,float)>(v, v);
goto label;
label:
v = v instanceof org.apache.qpid.proton.amqp.Binary;
if v == 0 goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
interfaceinvoke v.<javax.jms.Message: void setStringProperty(java.lang.String,java.lang.String)>(v, v);
goto label;
label:
interfaceinvoke v.<javax.jms.Message: void setObjectProperty(java.lang.String,java.lang.Object)>(v, v);
label:
return;
}
}