public class org.apache.activemq.transport.amqp.message.AMQPRawInboundTransformer extends org.apache.activemq.transport.amqp.message.InboundTransformer
{
public void <init>()
{
org.apache.activemq.transport.amqp.message.AMQPRawInboundTransformer v;
v := @this: org.apache.activemq.transport.amqp.message.AMQPRawInboundTransformer;
specialinvoke v.<org.apache.activemq.transport.amqp.message.InboundTransformer: void <init>()>();
return;
}
public java.lang.String getTransformerName()
{
org.apache.activemq.transport.amqp.message.AMQPRawInboundTransformer v;
v := @this: org.apache.activemq.transport.amqp.message.AMQPRawInboundTransformer;
return "raw";
}
public org.apache.activemq.transport.amqp.message.InboundTransformer getFallbackTransformer()
{
org.apache.activemq.transport.amqp.message.AMQPRawInboundTransformer v;
v := @this: org.apache.activemq.transport.amqp.message.AMQPRawInboundTransformer;
return null;
}
protected org.apache.activemq.command.ActiveMQMessage doTransform(org.apache.activemq.transport.amqp.message.EncodedMessage) throws java.lang.Exception
{
org.apache.activemq.command.ActiveMQBytesMessage v;
byte[] v;
long v, v, v;
org.apache.activemq.transport.amqp.message.EncodedMessage v;
byte v;
int v, v;
org.apache.activemq.transport.amqp.message.AMQPRawInboundTransformer v;
org.apache.activemq.util.ByteSequence v;
v := @this: org.apache.activemq.transport.amqp.message.AMQPRawInboundTransformer;
v := @parameter: org.apache.activemq.transport.amqp.message.EncodedMessage;
v = new org.apache.activemq.command.ActiveMQBytesMessage;
specialinvoke v.<org.apache.activemq.command.ActiveMQBytesMessage: void <init>()>();
v = new org.apache.activemq.util.ByteSequence;
v = virtualinvoke v.<org.apache.activemq.transport.amqp.message.EncodedMessage: byte[] getArray()>();
v = virtualinvoke v.<org.apache.activemq.transport.amqp.message.EncodedMessage: int getArrayOffset()>();
v = virtualinvoke v.<org.apache.activemq.transport.amqp.message.EncodedMessage: int getLength()>();
specialinvoke v.<org.apache.activemq.util.ByteSequence: void <init>(byte[],int,int)>(v, v, v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQBytesMessage: void setContent(org.apache.activemq.util.ByteSequence)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQBytesMessage: void setPersistent(boolean)>(1);
virtualinvoke v.<org.apache.activemq.command.ActiveMQBytesMessage: void setPriority(byte)>(4);
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQBytesMessage: void setTimestamp(long)>(v);
v = virtualinvoke v.<org.apache.activemq.transport.amqp.message.EncodedMessage: long getMessageFormat()>();
v = v cmp 0L;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.transport.amqp.message.EncodedMessage: long getMessageFormat()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQBytesMessage: void setLongProperty(java.lang.String,long)>("JMS_AMQP_MESSAGE_FORMAT", v);
label:
virtualinvoke v.<org.apache.activemq.command.ActiveMQBytesMessage: void setBooleanProperty(java.lang.String,boolean)>("JMS_AMQP_NATIVE", 1);
return v;
}
}