public final class org.apache.activemq.ActiveMQMessageTransformation extends java.lang.Object
{
private void <init>()
{
org.apache.activemq.ActiveMQMessageTransformation v;
v := @this: org.apache.activemq.ActiveMQMessageTransformation;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination transform(javax.jms.Destination)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQMessage transformMessage(javax.jms.Message, org.apache.activemq.ActiveMQConnection) throws javax.jms.JMSException
{
java.util.Enumeration v;
java.net.URL v;
org.apache.activemq.command.ActiveMQMessage v, v;
byte v;
boolean v, v, v, v, v, v, v, v;
org.apache.activemq.ActiveMQConnection v;
org.apache.activemq.command.ActiveMQBlobMessage v;
java.io.Serializable v;
org.apache.activemq.blob.BlobTransferPolicy v;
java.lang.Throwable v, v, v;
org.apache.activemq.command.ActiveMQBytesMessage v;
org.apache.activemq.command.ActiveMQTextMessage v;
org.apache.activemq.command.ActiveMQObjectMessage v;
java.lang.String v, v;
org.apache.activemq.blob.BlobDownloader v;
javax.jms.Message v;
java.net.MalformedURLException v;
org.apache.activemq.command.ActiveMQMapMessage v;
org.apache.activemq.command.ActiveMQStreamMessage v;
java.lang.Object v, v, v;
v := @parameter: javax.jms.Message;
v := @parameter: org.apache.activemq.ActiveMQConnection;
v = v instanceof org.apache.activemq.command.ActiveMQMessage;
if v == 0 goto label;
return v;
label:
v = v instanceof javax.jms.BytesMessage;
if v == 0 goto label;
interfaceinvoke v.<javax.jms.BytesMessage: void reset()>();
v = new org.apache.activemq.command.ActiveMQBytesMessage;
specialinvoke v.<org.apache.activemq.command.ActiveMQBytesMessage: void <init>()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQBytesMessage: void setConnection(org.apache.activemq.ActiveMQConnection)>(v);
label:
v = interfaceinvoke v.<javax.jms.BytesMessage: byte readByte()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQBytesMessage: void writeByte(byte)>(v);
goto label;
label:
v := @caughtexception;
v = v;
goto label;
label:
v = v instanceof javax.jms.MapMessage;
if v == 0 goto label;
v = new org.apache.activemq.command.ActiveMQMapMessage;
specialinvoke v.<org.apache.activemq.command.ActiveMQMapMessage: void <init>()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQMapMessage: void setConnection(org.apache.activemq.ActiveMQConnection)>(v);
v = interfaceinvoke v.<javax.jms.MapMessage: java.util.Enumeration getMapNames()>();
label:
v = interfaceinvoke v.<java.util.Enumeration: boolean hasMoreElements()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Enumeration: java.lang.Object nextElement()>();
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = interfaceinvoke v.<javax.jms.MapMessage: java.lang.Object getObject(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMapMessage: void setObject(java.lang.String,java.lang.Object)>(v, v);
goto label;
label:
v = v;
goto label;
label:
v = v instanceof javax.jms.ObjectMessage;
if v == 0 goto label;
v = new org.apache.activemq.command.ActiveMQObjectMessage;
specialinvoke v.<org.apache.activemq.command.ActiveMQObjectMessage: void <init>()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQObjectMessage: void setConnection(org.apache.activemq.ActiveMQConnection)>(v);
v = interfaceinvoke v.<javax.jms.ObjectMessage: java.io.Serializable getObject()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQObjectMessage: void setObject(java.io.Serializable)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQObjectMessage: void storeContent()>();
v = v;
goto label;
label:
v = v instanceof javax.jms.StreamMessage;
if v == 0 goto label;
interfaceinvoke v.<javax.jms.StreamMessage: void reset()>();
v = new org.apache.activemq.command.ActiveMQStreamMessage;
specialinvoke v.<org.apache.activemq.command.ActiveMQStreamMessage: void <init>()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQStreamMessage: void setConnection(org.apache.activemq.ActiveMQConnection)>(v);
label:
v = interfaceinvoke v.<javax.jms.StreamMessage: java.lang.Object readObject()>();
if v == null goto label;
virtualinvoke v.<org.apache.activemq.command.ActiveMQStreamMessage: void writeObject(java.lang.Object)>(v);
goto label;
label:
v := @caughtexception;
goto label;
label:
v := @caughtexception;
label:
v = v;
goto label;
label:
v = v instanceof javax.jms.TextMessage;
if v == 0 goto label;
v = new org.apache.activemq.command.ActiveMQTextMessage;
specialinvoke v.<org.apache.activemq.command.ActiveMQTextMessage: void <init>()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQTextMessage: void setConnection(org.apache.activemq.ActiveMQConnection)>(v);
v = interfaceinvoke v.<javax.jms.TextMessage: java.lang.String getText()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQTextMessage: void setText(java.lang.String)>(v);
v = v;
goto label;
label:
v = v instanceof org.apache.activemq.BlobMessage;
if v == 0 goto label;
v = new org.apache.activemq.command.ActiveMQBlobMessage;
specialinvoke v.<org.apache.activemq.command.ActiveMQBlobMessage: void <init>()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQBlobMessage: void setConnection(org.apache.activemq.ActiveMQConnection)>(v);
if v == null goto label;
v = new org.apache.activemq.blob.BlobDownloader;
v = virtualinvoke v.<org.apache.activemq.ActiveMQConnection: org.apache.activemq.blob.BlobTransferPolicy getBlobTransferPolicy()>();
specialinvoke v.<org.apache.activemq.blob.BlobDownloader: void <init>(org.apache.activemq.blob.BlobTransferPolicy)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQBlobMessage: void setBlobDownloader(org.apache.activemq.blob.BlobDownloader)>(v);
label:
v = interfaceinvoke v.<org.apache.activemq.BlobMessage: java.net.URL getURL()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQBlobMessage: void setURL(java.net.URL)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
v = v;
goto label;
label:
v = new org.apache.activemq.command.ActiveMQMessage;
specialinvoke v.<org.apache.activemq.command.ActiveMQMessage: void <init>()>();
v = v;
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setConnection(org.apache.activemq.ActiveMQConnection)>(v);
label:
staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: void copyProperties(javax.jms.Message,javax.jms.Message)>(v, v);
return v;
catch javax.jms.JMSException from label to label with label;
catch javax.jms.MessageEOFException from label to label with label;
catch javax.jms.JMSException from label to label with label;
catch java.net.MalformedURLException from label to label with label;
}
public static void copyProperties(javax.jms.Message, javax.jms.Message) throws javax.jms.JMSException
{
java.util.Enumeration v;
long v, v;
int v, v;
java.lang.String v, v, v, v;
javax.jms.Message v, v;
boolean v, v;
org.apache.activemq.command.ActiveMQDestination v, v;
javax.jms.Destination v, v;
java.lang.Object v, v;
v := @parameter: javax.jms.Message;
v := @parameter: javax.jms.Message;
v = interfaceinvoke v.<javax.jms.Message: java.lang.String getJMSMessageID()>();
interfaceinvoke v.<javax.jms.Message: void setJMSMessageID(java.lang.String)>(v);
v = interfaceinvoke v.<javax.jms.Message: java.lang.String getJMSCorrelationID()>();
interfaceinvoke v.<javax.jms.Message: void setJMSCorrelationID(java.lang.String)>(v);
v = interfaceinvoke v.<javax.jms.Message: javax.jms.Destination getJMSReplyTo()>();
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
interfaceinvoke v.<javax.jms.Message: void setJMSReplyTo(javax.jms.Destination)>(v);
v = interfaceinvoke v.<javax.jms.Message: javax.jms.Destination getJMSDestination()>();
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
interfaceinvoke v.<javax.jms.Message: void setJMSDestination(javax.jms.Destination)>(v);
v = interfaceinvoke v.<javax.jms.Message: int getJMSDeliveryMode()>();
interfaceinvoke v.<javax.jms.Message: void setJMSDeliveryMode(int)>(v);
v = interfaceinvoke v.<javax.jms.Message: boolean getJMSRedelivered()>();
interfaceinvoke v.<javax.jms.Message: void setJMSRedelivered(boolean)>(v);
v = interfaceinvoke v.<javax.jms.Message: java.lang.String getJMSType()>();
interfaceinvoke v.<javax.jms.Message: void setJMSType(java.lang.String)>(v);
v = interfaceinvoke v.<javax.jms.Message: long getJMSExpiration()>();
interfaceinvoke v.<javax.jms.Message: void setJMSExpiration(long)>(v);
v = interfaceinvoke v.<javax.jms.Message: int getJMSPriority()>();
interfaceinvoke v.<javax.jms.Message: void setJMSPriority(int)>(v);
v = interfaceinvoke v.<javax.jms.Message: long getJMSTimestamp()>();
interfaceinvoke v.<javax.jms.Message: void setJMSTimestamp(long)>(v);
v = interfaceinvoke v.<javax.jms.Message: java.util.Enumeration getPropertyNames()>();
label:
v = interfaceinvoke v.<java.util.Enumeration: boolean hasMoreElements()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Enumeration: java.lang.Object nextElement()>();
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = interfaceinvoke v.<javax.jms.Message: java.lang.Object getObjectProperty(java.lang.String)>(v);
interfaceinvoke v.<javax.jms.Message: void setObjectProperty(java.lang.String,java.lang.Object)>(v, v);
goto label;
label:
return;
}
}