public class org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer extends java.lang.Object implements org.apache.activemq.transport.amqp.message.OutboundTransformer
{
public static final org.apache.qpid.proton.amqp.Symbol JMS_DEST_TYPE_MSG_ANNOTATION;
public static final org.apache.qpid.proton.amqp.Symbol JMS_REPLY_TO_TYPE_MSG_ANNOTATION;
private static final java.lang.String AMQ_SCHEDULED_MESSAGE_PREFIX;
public static final byte QUEUE_TYPE;
public static final byte TOPIC_TYPE;
public static final byte TEMP_QUEUE_TYPE;
public static final byte TEMP_TOPIC_TYPE;
private final org.apache.activemq.transport.amqp.message.UTF8BufferType utf8BufferEncoding;
private final org.apache.qpid.proton.codec.DecoderImpl decoder;
private final org.apache.qpid.proton.codec.EncoderImpl encoder;
public void <init>()
{
org.apache.qpid.proton.codec.EncoderImpl v, v, v, v;
org.apache.activemq.transport.amqp.message.UTF8BufferType v, v;
org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer v;
org.apache.qpid.proton.codec.DecoderImpl v, v, v, v;
v := @this: org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.apache.qpid.proton.codec.DecoderImpl;
specialinvoke v.<org.apache.qpid.proton.codec.DecoderImpl: void <init>()>();
v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.codec.DecoderImpl decoder> = v;
v = new org.apache.qpid.proton.codec.EncoderImpl;
v = v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.codec.DecoderImpl decoder>;
specialinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void <init>(org.apache.qpid.proton.codec.DecoderImpl)>(v);
v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.codec.EncoderImpl encoder> = v;
v = v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.codec.DecoderImpl decoder>;
v = v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.codec.EncoderImpl encoder>;
staticinvoke <org.apache.qpid.proton.codec.AMQPDefinedTypes: void registerAllTypes(org.apache.qpid.proton.codec.Decoder,org.apache.qpid.proton.codec.EncoderImpl)>(v, v);
v = new org.apache.activemq.transport.amqp.message.UTF8BufferType;
v = v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.codec.EncoderImpl encoder>;
v = v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.codec.DecoderImpl decoder>;
specialinvoke v.<org.apache.activemq.transport.amqp.message.UTF8BufferType: void <init>(org.apache.qpid.proton.codec.EncoderImpl,org.apache.qpid.proton.codec.DecoderImpl)>(v, v);
v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.activemq.transport.amqp.message.UTF8BufferType utf8BufferEncoding> = v;
v = v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.codec.EncoderImpl encoder>;
v = v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.activemq.transport.amqp.message.UTF8BufferType utf8BufferEncoding>;
virtualinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void register(org.apache.qpid.proton.codec.AMQPType)>(v);
return;
}
public org.apache.activemq.transport.amqp.message.EncodedMessage transform(org.apache.activemq.command.ActiveMQMessage) throws java.lang.Exception
{
byte[] v, v;
byte v, v, v, v, v, v, v;
java.util.Map v;
org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer v;
org.apache.activemq.transport.amqp.message.EncodedMessage v;
org.apache.activemq.command.DataStructure v;
org.apache.qpid.proton.amqp.messaging.MessageAnnotations v;
long v, v, v, v, v;
org.apache.qpid.proton.amqp.Symbol v, v, v, v, v, v, v;
org.apache.qpid.proton.amqp.UnsignedByte v;
org.apache.qpid.proton.codec.EncoderImpl v, v, v, v, v, v, v, v;
java.io.IOException v;
org.apache.qpid.proton.amqp.messaging.Header v, v, v, v, v, v, v;
java.util.Date v, v;
org.apache.activemq.command.ActiveMQMessage v;
org.apache.qpid.proton.amqp.messaging.Footer v;
org.apache.activemq.command.MessageId v;
org.apache.activemq.command.ActiveMQDestination v, v;
org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations v;
java.nio.charset.Charset v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Boolean v, v;
org.apache.qpid.proton.amqp.messaging.Properties v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.qpid.proton.amqp.messaging.ApplicationProperties v;
org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper v;
java.lang.Class v;
java.lang.Object v, v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.transport.amqp.AmqpProtocolException v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v, v;
java.util.Set v;
org.apache.activemq.transport.amqp.message.AmqpWritableBuffer v;
org.apache.qpid.proton.amqp.messaging.Section v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.qpid.proton.amqp.Binary v;
java.lang.Byte v, v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
javax.jms.JMSException v;
java.util.HashMap v, v, v, v, v, v, v, v, v, v;
java.util.Iterator v;
v := @this: org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer;
v := @parameter: org.apache.activemq.command.ActiveMQMessage;
if v != null goto label;
return null;
label:
v = 0L;
v = null;
v = null;
v = null;
v = null;
v = null;
v = null;
v = specialinvoke v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.amqp.messaging.Section convertBody(org.apache.activemq.command.ActiveMQMessage)>(v);
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: boolean isPersistent()>();
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 = v;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: void setDurable(java.lang.Boolean)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: byte getPriority()>();
if v == 4 goto label;
if v != null goto label;
v = new org.apache.qpid.proton.amqp.messaging.Header;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: void <init>()>();
v = v;
label:
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);
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.String getType()>();
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 = v;
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setSubject(java.lang.String)>(v);
label:
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 = new org.apache.qpid.proton.amqp.messaging.Properties;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void <init>()>();
v = v;
label:
v = staticinvoke <org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: java.lang.Object getOriginalMessageId(org.apache.activemq.command.ActiveMQMessage)>(v);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setMessageId(java.lang.Object)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.command.ActiveMQDestination getDestination()>();
if v == null goto label;
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 = v;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getQualifiedName()>();
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setTo(java.lang.String)>(v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = v;
v = <org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.amqp.Symbol JMS_DEST_TYPE_MSG_ANNOTATION>;
v = staticinvoke <org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: byte destinationType(org.apache.activemq.command.ActiveMQDestination)>(v);
v = staticinvoke <java.lang.Byte: java.lang.Byte valueOf(byte)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.command.ActiveMQDestination getReplyTo()>();
if v == null goto label;
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 = v;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getQualifiedName()>();
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setReplyTo(java.lang.String)>(v);
if v != null goto label;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = v;
label:
v = <org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.amqp.Symbol JMS_REPLY_TO_TYPE_MSG_ANNOTATION>;
v = staticinvoke <org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: byte destinationType(org.apache.activemq.command.ActiveMQDestination)>(v);
v = staticinvoke <java.lang.Byte: java.lang.Byte valueOf(byte)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.String getCorrelationId()>();
if v == null goto label;
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 = v;
label:
v = <org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper: org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper INSTANCE>;
v = virtualinvoke v.<org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper: java.lang.Object toIdObject(java.lang.String)>(v);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setCorrelationId(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setCorrelationId(java.lang.Object)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: long getExpiration()>();
v = v cmp 0L;
if v == 0 goto label;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v - v;
v = v cmp 0L;
if v >= 0 goto label;
v = 1L;
label:
if v != null goto label;
v = new org.apache.qpid.proton.amqp.messaging.Header;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: void <init>()>();
v = v;
label:
v = new org.apache.qpid.proton.amqp.UnsignedInteger;
specialinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: void <init>(int)>(v);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: void setTtl(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
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 = v;
label:
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);
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: long getTimestamp()>();
v = v cmp 0L;
if v == 0 goto label;
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 = v;
label:
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);
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: int getRedeliveryCounter()>();
if v <= 0 goto label;
if v != null goto label;
v = new org.apache.qpid.proton.amqp.messaging.Header;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: void <init>()>();
v = v;
label:
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.Header: void setDeliveryCount(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.String getUserID()>();
if v == null goto label;
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 = v;
label:
v = new org.apache.qpid.proton.amqp.Binary;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
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:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.String getGroupID()>();
if v == null goto label;
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 = v;
label:
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setGroupId(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: int getGroupSequence()>();
if v <= 0 goto label;
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 = v;
label:
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);
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.util.Map getProperties()>();
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <org.apache.activemq.util.JMSExceptionSupport: javax.jms.JMSException create(java.lang.Exception)>(v);
throw v;
label:
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()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("JMS_AMQP_");
if v == 0 goto label;
v = <org.apache.activemq.transport.amqp.message.AmqpMessageSupport: int JMS_AMQP_PREFIX_LENGTH>;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String,int)>("NATIVE", v);
if v != 0 goto label;
v = <org.apache.activemq.transport.amqp.message.AmqpMessageSupport: int JMS_AMQP_PREFIX_LENGTH>;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String,int)>("ORIGINAL_ENCODING", v);
if v != 0 goto label;
v = <org.apache.activemq.transport.amqp.message.AmqpMessageSupport: int JMS_AMQP_PREFIX_LENGTH>;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String,int)>("MESSAGE_FORMAT", v);
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = staticinvoke <org.apache.activemq.util.TypeConversionSupport: java.lang.Object convert(java.lang.Object,java.lang.Class)>(v, class "Ljava/lang/Long;");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
goto label;
label:
v = <org.apache.activemq.transport.amqp.message.AmqpMessageSupport: int JMS_AMQP_PREFIX_LENGTH>;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String,int)>("HEADER", v);
if v == 0 goto label;
if v != null goto label;
v = new org.apache.qpid.proton.amqp.messaging.Header;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: void <init>()>();
v = v;
goto label;
label:
v = <org.apache.activemq.transport.amqp.message.AmqpMessageSupport: int JMS_AMQP_PREFIX_LENGTH>;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String,int)>("PROPERTIES", v);
if v == 0 goto label;
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 = v;
goto label;
label:
v = <org.apache.activemq.transport.amqp.message.AmqpMessageSupport: int JMS_AMQP_PREFIX_LENGTH>;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String,int)>("MA_", v);
if v == 0 goto label;
if v != null goto label;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = v;
label:
v = "JMS_AMQP_MA_";
v = virtualinvoke v.<java.lang.String: int length()>();
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
v = staticinvoke <org.apache.qpid.proton.amqp.Symbol: org.apache.qpid.proton.amqp.Symbol valueOf(java.lang.String)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = <org.apache.activemq.transport.amqp.message.AmqpMessageSupport: int JMS_AMQP_PREFIX_LENGTH>;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String,int)>("FirstAcquirer", v);
if v == 0 goto label;
if v != null goto label;
v = new org.apache.qpid.proton.amqp.messaging.Header;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Header: void <init>()>();
v = v;
label:
v = staticinvoke <org.apache.activemq.util.TypeConversionSupport: java.lang.Object convert(java.lang.Object,java.lang.Class)>(v, class "Ljava/lang/Boolean;");
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
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);
goto label;
label:
v = <org.apache.activemq.transport.amqp.message.AmqpMessageSupport: int JMS_AMQP_PREFIX_LENGTH>;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String,int)>("ContentType", v);
if v == 0 goto label;
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 = v;
label:
v = staticinvoke <org.apache.activemq.util.TypeConversionSupport: java.lang.Object convert(java.lang.Object,java.lang.Class)>(v, class "Ljava/lang/String;");
v = staticinvoke <org.apache.qpid.proton.amqp.Symbol: org.apache.qpid.proton.amqp.Symbol getSymbol(java.lang.String)>(v);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setContentType(org.apache.qpid.proton.amqp.Symbol)>(v);
goto label;
label:
v = <org.apache.activemq.transport.amqp.message.AmqpMessageSupport: int JMS_AMQP_PREFIX_LENGTH>;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String,int)>("ContentEncoding", v);
if v == 0 goto label;
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 = v;
label:
v = staticinvoke <org.apache.activemq.util.TypeConversionSupport: java.lang.Object convert(java.lang.Object,java.lang.Class)>(v, class "Ljava/lang/String;");
v = staticinvoke <org.apache.qpid.proton.amqp.Symbol: org.apache.qpid.proton.amqp.Symbol getSymbol(java.lang.String)>(v);
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setContentEncoding(org.apache.qpid.proton.amqp.Symbol)>(v);
goto label;
label:
v = <org.apache.activemq.transport.amqp.message.AmqpMessageSupport: int JMS_AMQP_PREFIX_LENGTH>;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String,int)>("ReplyToGroupID", v);
if v == 0 goto label;
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 = v;
label:
v = staticinvoke <org.apache.activemq.util.TypeConversionSupport: java.lang.Object convert(java.lang.Object,java.lang.Class)>(v, class "Ljava/lang/String;");
virtualinvoke v.<org.apache.qpid.proton.amqp.messaging.Properties: void setReplyToGroupId(java.lang.String)>(v);
goto label;
label:
v = <org.apache.activemq.transport.amqp.message.AmqpMessageSupport: int JMS_AMQP_PREFIX_LENGTH>;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String,int)>("DA_", v);
if v == 0 goto label;
if v != null goto label;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = v;
label:
v = "JMS_AMQP_DA_";
v = virtualinvoke v.<java.lang.String: int length()>();
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
v = staticinvoke <org.apache.qpid.proton.amqp.Symbol: org.apache.qpid.proton.amqp.Symbol valueOf(java.lang.String)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = <org.apache.activemq.transport.amqp.message.AmqpMessageSupport: int JMS_AMQP_PREFIX_LENGTH>;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String,int)>("FT_", v);
if v == 0 goto label;
if v != null goto label;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = v;
label:
v = "JMS_AMQP_FT_";
v = virtualinvoke v.<java.lang.String: int length()>();
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
v = staticinvoke <org.apache.qpid.proton.amqp.Symbol: org.apache.qpid.proton.amqp.Symbol valueOf(java.lang.String)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("AMQ_SCHEDULED_");
if v != 0 goto label;
label:
if v != null goto label;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = v;
label:
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: byte getDataStructureType()>();
if v != 23 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.command.DataStructure getDataStructure()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("ActiveMqDataStructureType", v);
goto label;
label:
v = new org.apache.activemq.transport.amqp.message.AmqpWritableBuffer;
specialinvoke v.<org.apache.activemq.transport.amqp.message.AmqpWritableBuffer: void <init>()>();
v = v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.codec.EncoderImpl encoder>;
virtualinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void setByteBuffer(org.apache.qpid.proton.codec.WritableBuffer)>(v);
if v == null goto label;
v = v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.codec.EncoderImpl encoder>;
virtualinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void writeObject(java.lang.Object)>(v);
label:
if v == null goto label;
v = v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.codec.EncoderImpl encoder>;
v = new org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations: void <init>(java.util.Map)>(v);
virtualinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void writeObject(java.lang.Object)>(v);
label:
if v == null goto label;
v = v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.codec.EncoderImpl encoder>;
v = new org.apache.qpid.proton.amqp.messaging.MessageAnnotations;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.MessageAnnotations: void <init>(java.util.Map)>(v);
virtualinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void writeObject(java.lang.Object)>(v);
label:
if v == null goto label;
v = v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.codec.EncoderImpl encoder>;
virtualinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void writeObject(java.lang.Object)>(v);
label:
if v == null goto label;
v = v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.codec.EncoderImpl encoder>;
v = new org.apache.qpid.proton.amqp.messaging.ApplicationProperties;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.ApplicationProperties: void <init>(java.util.Map)>(v);
virtualinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void writeObject(java.lang.Object)>(v);
label:
if v == null goto label;
v = v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.codec.EncoderImpl encoder>;
virtualinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void writeObject(java.lang.Object)>(v);
label:
if v == null goto label;
v = v.<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.codec.EncoderImpl encoder>;
v = new org.apache.qpid.proton.amqp.messaging.Footer;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Footer: void <init>(java.util.Map)>(v);
virtualinvoke v.<org.apache.qpid.proton.codec.EncoderImpl: void writeObject(java.lang.Object)>(v);
label:
v = new org.apache.activemq.transport.amqp.message.EncodedMessage;
v = virtualinvoke v.<org.apache.activemq.transport.amqp.message.AmqpWritableBuffer: byte[] getArray()>();
v = virtualinvoke v.<org.apache.activemq.transport.amqp.message.AmqpWritableBuffer: int getArrayLength()>();
specialinvoke v.<org.apache.activemq.transport.amqp.message.EncodedMessage: void <init>(long,byte[],int,int)>(v, v, 0, v);
return v;
catch org.apache.activemq.transport.amqp.AmqpProtocolException from label to label with label;
catch java.io.IOException from label to label with label;
}
private org.apache.qpid.proton.amqp.messaging.Section convertBody(org.apache.activemq.command.ActiveMQMessage) throws javax.jms.JMSException
{
byte v;
java.lang.Long v, v, v;
java.util.Map v;
org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer v;
org.apache.activemq.command.SessionId v;
java.lang.Exception v;
org.apache.qpid.proton.amqp.messaging.Section v;
org.apache.activemq.command.DataStructure v, v, v, v, v, v, v;
long v, v, v;
java.util.ArrayList v;
java.util.LinkedHashMap v, v;
short v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.apache.activemq.command.ActiveMQMessage v;
org.apache.qpid.proton.amqp.Binary v, v, v;
boolean v, v, v, v, v, v, v, v, v, v;
org.apache.qpid.proton.amqp.messaging.Data v, v, v;
org.apache.qpid.proton.amqp.messaging.AmqpValue v, v, v, v, v, v;
java.lang.Boolean v, v, v, v, v;
org.apache.activemq.command.ConnectionId v;
java.lang.Class v, v;
java.lang.Object v;
v := @this: org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer;
v := @parameter: org.apache.activemq.command.ActiveMQMessage;
v = null;
v = 0;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: short getShortProperty(java.lang.String)>("JMS_AMQP_ORIGINAL_ENCODING");
label:
goto label;
label:
v := @caughtexception;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: byte getDataStructureType()>();
if v != 23 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.command.DataStructure getDataStructure()>();
v = v instanceof org.apache.activemq.command.ConnectionInfo;
if v == 0 goto label;
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.command.ConnectionInfo: org.apache.activemq.command.ConnectionId getConnectionId()>();
v = virtualinvoke v.<org.apache.activemq.command.ConnectionId: java.lang.String getValue()>();
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("ConnectionId", v);
v = virtualinvoke v.<org.apache.activemq.command.ConnectionInfo: java.lang.String getClientId()>();
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("ClientId", v);
v = virtualinvoke v.<org.apache.activemq.command.ConnectionInfo: java.lang.String getClientIp()>();
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("ClientIp", v);
v = virtualinvoke v.<org.apache.activemq.command.ConnectionInfo: java.lang.String getUserName()>();
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("UserName", v);
v = virtualinvoke v.<org.apache.activemq.command.ConnectionInfo: boolean isBrokerMasterConnector()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("BrokerMasterConnector", v);
v = virtualinvoke v.<org.apache.activemq.command.ConnectionInfo: boolean isManageable()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("Manageable", v);
v = virtualinvoke v.<org.apache.activemq.command.ConnectionInfo: boolean isClientMaster()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("ClientMaster", v);
v = virtualinvoke v.<org.apache.activemq.command.ConnectionInfo: boolean isFaultTolerant()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("FaultTolerant", v);
v = virtualinvoke v.<org.apache.activemq.command.ConnectionInfo: boolean isFailoverReconnect()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("FailoverReconnect", v);
v = new org.apache.qpid.proton.amqp.messaging.AmqpValue;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.AmqpValue: void <init>(java.lang.Object)>(v);
v = v;
goto label;
label:
v = v instanceof org.apache.activemq.command.RemoveInfo;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.command.DataStructure getDataStructure()>();
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.command.RemoveInfo: boolean isConnectionRemove()>();
if v == 0 goto label;
v = class "Lorg/apache/activemq/command/ConnectionId;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = virtualinvoke v.<org.apache.activemq.command.RemoveInfo: org.apache.activemq.command.DataStructure getObjectId()>();
v = virtualinvoke v.<org.apache.activemq.command.ConnectionId: java.lang.String getValue()>();
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.command.RemoveInfo: boolean isConsumerRemove()>();
if v == 0 goto label;
v = class "Lorg/apache/activemq/command/ConsumerId;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = virtualinvoke v.<org.apache.activemq.command.RemoveInfo: org.apache.activemq.command.DataStructure getObjectId()>();
v = virtualinvoke v.<org.apache.activemq.command.ConsumerId: long getValue()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.activemq.command.RemoveInfo: org.apache.activemq.command.DataStructure getObjectId()>();
v = virtualinvoke v.<org.apache.activemq.command.ConsumerId: long getSessionId()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("SessionId", v);
v = virtualinvoke v.<org.apache.activemq.command.RemoveInfo: org.apache.activemq.command.DataStructure getObjectId()>();
v = virtualinvoke v.<org.apache.activemq.command.ConsumerId: java.lang.String getConnectionId()>();
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("ConnectionId", v);
v = virtualinvoke v.<org.apache.activemq.command.RemoveInfo: org.apache.activemq.command.DataStructure getObjectId()>();
v = virtualinvoke v.<org.apache.activemq.command.ConsumerId: org.apache.activemq.command.SessionId getParentId()>();
v = virtualinvoke v.<org.apache.activemq.command.SessionId: long getValue()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("ParentId", v);
label:
v = new org.apache.qpid.proton.amqp.messaging.AmqpValue;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.AmqpValue: void <init>(java.lang.Object)>(v);
v = v;
goto label;
label:
if v != 24 goto label;
v = staticinvoke <org.apache.activemq.transport.amqp.message.AmqpMessageSupport: org.apache.qpid.proton.amqp.Binary getBinaryFromMessageBody(org.apache.activemq.command.ActiveMQBytesMessage)>(v);
if v != null goto label;
v = <org.apache.activemq.transport.amqp.message.AmqpMessageSupport: org.apache.qpid.proton.amqp.Binary EMPTY_BINARY>;
label:
tableswitch(v)
{
case 0: goto label;
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
case 6: goto label;
default: goto label;
};
label:
v = new org.apache.qpid.proton.amqp.messaging.AmqpValue;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.AmqpValue: void <init>(java.lang.Object)>(v);
v = v;
goto label;
label:
v = new org.apache.qpid.proton.amqp.messaging.Data;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Data: void <init>(org.apache.qpid.proton.amqp.Binary)>(v);
v = v;
goto label;
label:
if v != 28 goto label;
tableswitch(v)
{
case 0: goto label;
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
default: goto label;
};
label:
v = new org.apache.qpid.proton.amqp.messaging.Data;
v = staticinvoke <org.apache.activemq.transport.amqp.message.AmqpMessageSupport: org.apache.qpid.proton.amqp.Binary getBinaryFromMessageBody(org.apache.activemq.command.ActiveMQTextMessage)>(v);
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Data: void <init>(org.apache.qpid.proton.amqp.Binary)>(v);
v = v;
goto label;
label:
v = new org.apache.qpid.proton.amqp.messaging.AmqpValue;
v = interfaceinvoke v.<javax.jms.TextMessage: java.lang.String getText()>();
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.AmqpValue: void <init>(java.lang.Object)>(v);
v = v;
goto label;
label:
if v != 25 goto label;
v = new org.apache.qpid.proton.amqp.messaging.AmqpValue;
v = staticinvoke <org.apache.activemq.transport.amqp.message.AmqpMessageSupport: java.util.Map getMapFromMessageBody(org.apache.activemq.command.ActiveMQMapMessage)>(v);
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.AmqpValue: void <init>(java.lang.Object)>(v);
v = v;
goto label;
label:
if v != 27 goto label;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQStreamMessage: java.lang.Object readObject()>();
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
goto label;
label:
if v != 26 goto label;
v = staticinvoke <org.apache.activemq.transport.amqp.message.AmqpMessageSupport: org.apache.qpid.proton.amqp.Binary getBinaryFromMessageBody(org.apache.activemq.command.ActiveMQObjectMessage)>(v);
if v != null goto label;
v = <org.apache.activemq.transport.amqp.message.AmqpMessageSupport: org.apache.qpid.proton.amqp.Binary EMPTY_BINARY>;
label:
lookupswitch(v)
{
case 0: goto label;
case 2: goto label;
case 6: goto label;
default: goto label;
};
label:
v = new org.apache.qpid.proton.amqp.messaging.AmqpValue;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.AmqpValue: void <init>(java.lang.Object)>(v);
v = v;
goto label;
label:
v = new org.apache.qpid.proton.amqp.messaging.Data;
specialinvoke v.<org.apache.qpid.proton.amqp.messaging.Data: void <init>(org.apache.qpid.proton.amqp.Binary)>(v);
v = v;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: boolean propertyExists(java.lang.String)>("JMS_AMQP_ContentType");
if v != 0 goto label;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setReadOnlyProperties(boolean)>(0);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setStringProperty(java.lang.String,java.lang.String)>("JMS_AMQP_ContentType", "application/x-java-serialized-object");
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setReadOnlyProperties(boolean)>(1);
label:
return v;
catch java.lang.Exception from label to label with label;
}
private static byte destinationType(org.apache.activemq.command.ActiveMQDestination)
{
java.lang.IllegalArgumentException v;
boolean v, v, v, v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isQueue()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTemporary()>();
if v == 0 goto label;
return 2;
label:
return 0;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTopic()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTemporary()>();
if v == 0 goto label;
return 3;
label:
return 1;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Unknown Destination Type passed to JMS Transformer.");
throw v;
}
private static java.lang.Object getOriginalMessageId(org.apache.activemq.command.ActiveMQMessage)
{
org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper v;
org.apache.activemq.command.MessageId v;
org.apache.activemq.command.ActiveMQMessage v;
java.lang.Object v;
org.apache.activemq.transport.amqp.AmqpProtocolException v;
java.lang.String v, v;
v := @parameter: org.apache.activemq.command.ActiveMQMessage;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.command.MessageId getMessageId()>();
v = virtualinvoke v.<org.apache.activemq.command.MessageId: java.lang.String getTextView()>();
if v == null goto label;
label:
v = <org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper: org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper INSTANCE>;
v = virtualinvoke v.<org.apache.activemq.command.MessageId: java.lang.String getTextView()>();
v = virtualinvoke v.<org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper: java.lang.Object toIdObject(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.activemq.command.MessageId: java.lang.String getTextView()>();
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.command.MessageId: java.lang.String toString()>();
label:
return v;
catch org.apache.activemq.transport.amqp.AmqpProtocolException from label to label with label;
}
static void <clinit>()
{
org.apache.qpid.proton.amqp.Symbol v, v;
v = staticinvoke <org.apache.qpid.proton.amqp.Symbol: org.apache.qpid.proton.amqp.Symbol valueOf(java.lang.String)>("x-opt-jms-dest");
<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.amqp.Symbol JMS_DEST_TYPE_MSG_ANNOTATION> = v;
v = staticinvoke <org.apache.qpid.proton.amqp.Symbol: org.apache.qpid.proton.amqp.Symbol valueOf(java.lang.String)>("x-opt-jms-reply-to");
<org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: org.apache.qpid.proton.amqp.Symbol JMS_REPLY_TO_TYPE_MSG_ANNOTATION> = v;
return;
}
}