public class org.apache.activemq.transport.stomp.JmsFrameTranslator extends org.apache.activemq.transport.stomp.LegacyFrameTranslator implements org.apache.activemq.broker.BrokerContextAware
{
com.thoughtworks.xstream.XStream xStream;
com.thoughtworks.xstream.XStream xStreamAdvisory;
org.apache.activemq.broker.BrokerContext brokerContext;
public void <init>()
{
org.apache.activemq.transport.stomp.JmsFrameTranslator v;
v := @this: org.apache.activemq.transport.stomp.JmsFrameTranslator;
specialinvoke v.<org.apache.activemq.transport.stomp.LegacyFrameTranslator: void <init>()>();
v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: com.thoughtworks.xstream.XStream xStream> = null;
v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: com.thoughtworks.xstream.XStream xStreamAdvisory> = null;
return;
}
public org.apache.activemq.command.ActiveMQMessage convertFrame(org.apache.activemq.transport.stomp.ProtocolConverter, org.apache.activemq.transport.stomp.StompFrame) throws javax.jms.JMSException, org.apache.activemq.transport.stomp.ProtocolException
{
byte[] v;
org.apache.activemq.command.ActiveMQMessage v;
org.apache.activemq.transport.stomp.JmsFrameTranslator v;
com.thoughtworks.xstream.io.json.JettisonMappedXmlDriver v, v;
int[] v;
java.util.Map v, v;
com.thoughtworks.xstream.io.xml.XppReader v, v;
boolean v, v;
org.xmlpull.v.XmlPullParser v, v;
org.apache.activemq.transport.stomp.Stomp$Transformations v, v;
java.lang.Exception v;
org.apache.activemq.transport.stomp.StompFrame v;
com.thoughtworks.xstream.io.HierarchicalStreamReader v, v;
java.lang.Throwable v;
org.apache.activemq.transport.stomp.ProtocolConverter v;
int v, v;
java.lang.String v, v, v, v;
java.io.StringReader v, v, v, v;
java.lang.Object v;
v := @this: org.apache.activemq.transport.stomp.JmsFrameTranslator;
v := @parameter: org.apache.activemq.transport.stomp.ProtocolConverter;
v := @parameter: org.apache.activemq.transport.stomp.StompFrame;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.StompFrame: java.util.Map getHeaders()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("transformation");
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("content-length");
if v != 0 goto label;
v = <org.apache.activemq.transport.stomp.Stomp$Transformations: org.apache.activemq.transport.stomp.Stomp$Transformations JMS_BYTE>;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.Stomp$Transformations: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = specialinvoke v.<org.apache.activemq.transport.stomp.LegacyFrameTranslator: org.apache.activemq.command.ActiveMQMessage convertFrame(org.apache.activemq.transport.stomp.ProtocolConverter,org.apache.activemq.transport.stomp.StompFrame)>(v, v);
goto label;
label:
v = new java.lang.String;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.StompFrame: byte[] getContent()>();
specialinvoke v.<java.lang.String: void <init>(byte[],java.lang.String)>(v, "UTF-8");
v = <org.apache.activemq.transport.stomp.JmsFrameTranslator$2: int[] $SwitchMap$org$apache$activemq$transport$stomp$Stomp$Transformations>;
v = staticinvoke <org.apache.activemq.transport.stomp.Stomp$Transformations: org.apache.activemq.transport.stomp.Stomp$Transformations getValue(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.transport.stomp.Stomp$Transformations: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
default: goto label;
};
label:
v = new com.thoughtworks.xstream.io.xml.XppReader;
v = new java.io.StringReader;
specialinvoke v.<java.io.StringReader: void <init>(java.lang.String)>(v);
v = staticinvoke <com.thoughtworks.xstream.io.xml.xppdom.XppFactory: org.xmlpull.v.XmlPullParser createDefaultParser()>();
specialinvoke v.<com.thoughtworks.xstream.io.xml.XppReader: void <init>(java.io.Reader,org.xmlpull.v.XmlPullParser)>(v, v);
v = virtualinvoke v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: org.apache.activemq.command.ActiveMQObjectMessage createObjectMessage(com.thoughtworks.xstream.io.HierarchicalStreamReader)>(v);
goto label;
label:
v = new com.thoughtworks.xstream.io.json.JettisonMappedXmlDriver;
specialinvoke v.<com.thoughtworks.xstream.io.json.JettisonMappedXmlDriver: void <init>()>();
v = new java.io.StringReader;
specialinvoke v.<java.io.StringReader: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<com.thoughtworks.xstream.io.json.JettisonMappedXmlDriver: com.thoughtworks.xstream.io.HierarchicalStreamReader createReader(java.io.Reader)>(v);
v = virtualinvoke v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: org.apache.activemq.command.ActiveMQObjectMessage createObjectMessage(com.thoughtworks.xstream.io.HierarchicalStreamReader)>(v);
goto label;
label:
v = new com.thoughtworks.xstream.io.xml.XppReader;
v = new java.io.StringReader;
specialinvoke v.<java.io.StringReader: void <init>(java.lang.String)>(v);
v = staticinvoke <com.thoughtworks.xstream.io.xml.xppdom.XppFactory: org.xmlpull.v.XmlPullParser createDefaultParser()>();
specialinvoke v.<com.thoughtworks.xstream.io.xml.XppReader: void <init>(java.io.Reader,org.xmlpull.v.XmlPullParser)>(v, v);
v = virtualinvoke v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: org.apache.activemq.command.ActiveMQMapMessage createMapMessage(com.thoughtworks.xstream.io.HierarchicalStreamReader)>(v);
goto label;
label:
v = new com.thoughtworks.xstream.io.json.JettisonMappedXmlDriver;
specialinvoke v.<com.thoughtworks.xstream.io.json.JettisonMappedXmlDriver: void <init>()>();
v = new java.io.StringReader;
specialinvoke v.<java.io.StringReader: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<com.thoughtworks.xstream.io.json.JettisonMappedXmlDriver: com.thoughtworks.xstream.io.HierarchicalStreamReader createReader(java.io.Reader)>(v);
v = virtualinvoke v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: org.apache.activemq.command.ActiveMQMapMessage createMapMessage(com.thoughtworks.xstream.io.HierarchicalStreamReader)>(v);
goto label;
label:
v = new java.lang.Exception;
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[])>("Unknown transformation: \u0001");
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>(v);
throw v;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.StompFrame: java.util.Map getHeaders()>();
v = virtualinvoke v.<java.lang.Throwable: java.lang.String getMessage()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("transformation-error", v);
v = specialinvoke v.<org.apache.activemq.transport.stomp.LegacyFrameTranslator: org.apache.activemq.command.ActiveMQMessage convertFrame(org.apache.activemq.transport.stomp.ProtocolConverter,org.apache.activemq.transport.stomp.StompFrame)>(v, v);
label:
staticinvoke <org.apache.activemq.transport.stomp.FrameTranslator$Helper: void copyStandardHeadersFromFrameToMessage(org.apache.activemq.transport.stomp.ProtocolConverter,org.apache.activemq.transport.stomp.StompFrame,org.apache.activemq.command.ActiveMQMessage,org.apache.activemq.transport.stomp.FrameTranslator)>(v, v, v, v);
return v;
catch java.lang.Throwable from label to label with label;
}
public org.apache.activemq.transport.stomp.StompFrame convertMessage(org.apache.activemq.transport.stomp.ProtocolConverter, org.apache.activemq.command.ActiveMQMessage) throws java.io.IOException, javax.jms.JMSException
{
byte[] v, v, v;
org.apache.activemq.command.ActiveMQMessage v;
org.apache.activemq.transport.stomp.JmsFrameTranslator v;
org.apache.activemq.command.Message v, v;
byte v, v, v;
java.util.Map v;
boolean v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.transport.stomp.Stomp$Transformations v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.io.Serializable v;
org.apache.activemq.transport.stomp.StompFrame v, v;
org.apache.activemq.command.DataStructure v;
java.util.HashMap v;
org.apache.activemq.transport.stomp.ProtocolConverter v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.activemq.transport.stomp.JmsFrameTranslator;
v := @parameter: org.apache.activemq.transport.stomp.ProtocolConverter;
v := @parameter: org.apache.activemq.command.ActiveMQMessage;
v = new org.apache.activemq.transport.stomp.StompFrame;
specialinvoke v.<org.apache.activemq.transport.stomp.StompFrame: void <init>()>();
v = v;
virtualinvoke v.<org.apache.activemq.transport.stomp.StompFrame: void setAction(java.lang.String)>("MESSAGE");
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(int)>(25);
virtualinvoke v.<org.apache.activemq.transport.stomp.StompFrame: void setHeaders(java.util.Map)>(v);
staticinvoke <org.apache.activemq.transport.stomp.FrameTranslator$Helper: void copyStandardHeadersFromMessageToFrame(org.apache.activemq.transport.stomp.ProtocolConverter,org.apache.activemq.command.ActiveMQMessage,org.apache.activemq.transport.stomp.StompFrame,org.apache.activemq.transport.stomp.FrameTranslator)>(v, v, v, v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("transformation");
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: byte getDataStructureType()>();
if v != 26 goto label;
v = <org.apache.activemq.transport.stomp.Stomp$Transformations: org.apache.activemq.transport.stomp.Stomp$Transformations JMS_XML>;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.Stomp$Transformations: boolean equals(java.lang.String)>(v);
if v == 0 goto label;
v = <org.apache.activemq.transport.stomp.Stomp$Transformations: org.apache.activemq.transport.stomp.Stomp$Transformations JMS_OBJECT_XML>;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.Stomp$Transformations: java.lang.String toString()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("transformation", v);
goto label;
label:
v = <org.apache.activemq.transport.stomp.Stomp$Transformations: org.apache.activemq.transport.stomp.Stomp$Transformations JMS_JSON>;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.Stomp$Transformations: boolean equals(java.lang.String)>(v);
if v == 0 goto label;
v = <org.apache.activemq.transport.stomp.Stomp$Transformations: org.apache.activemq.transport.stomp.Stomp$Transformations JMS_OBJECT_JSON>;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.Stomp$Transformations: java.lang.String toString()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("transformation", v);
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("transformation");
if v != 0 goto label;
v = <org.apache.activemq.transport.stomp.Stomp$Transformations: org.apache.activemq.transport.stomp.Stomp$Transformations JMS_OBJECT_XML>;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.Stomp$Transformations: java.lang.String toString()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("transformation", v);
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.command.Message copy()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQObjectMessage: java.io.Serializable getObject()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("transformation");
v = virtualinvoke v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: java.lang.String marshall(java.io.Serializable,java.lang.String)>(v, v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.lang.String)>("UTF-8");
virtualinvoke v.<org.apache.activemq.transport.stomp.StompFrame: void setContent(byte[])>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: byte getDataStructureType()>();
if v != 25 goto label;
v = <org.apache.activemq.transport.stomp.Stomp$Transformations: org.apache.activemq.transport.stomp.Stomp$Transformations JMS_XML>;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.Stomp$Transformations: boolean equals(java.lang.String)>(v);
if v == 0 goto label;
v = <org.apache.activemq.transport.stomp.Stomp$Transformations: org.apache.activemq.transport.stomp.Stomp$Transformations JMS_MAP_XML>;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.Stomp$Transformations: java.lang.String toString()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("transformation", v);
goto label;
label:
v = <org.apache.activemq.transport.stomp.Stomp$Transformations: org.apache.activemq.transport.stomp.Stomp$Transformations JMS_JSON>;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.Stomp$Transformations: boolean equals(java.lang.String)>(v);
if v == 0 goto label;
v = <org.apache.activemq.transport.stomp.Stomp$Transformations: org.apache.activemq.transport.stomp.Stomp$Transformations JMS_MAP_JSON>;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.Stomp$Transformations: java.lang.String toString()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("transformation", v);
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("transformation");
if v != 0 goto label;
v = <org.apache.activemq.transport.stomp.Stomp$Transformations: org.apache.activemq.transport.stomp.Stomp$Transformations JMS_MAP_XML>;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.Stomp$Transformations: java.lang.String toString()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("transformation", v);
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.command.Message copy()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMapMessage: java.util.Map getContentMap()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("transformation");
v = virtualinvoke v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: java.lang.String marshall(java.io.Serializable,java.lang.String)>(v, v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.lang.String)>("UTF-8");
virtualinvoke v.<org.apache.activemq.transport.stomp.StompFrame: void setContent(byte[])>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: byte getDataStructureType()>();
if v != 23 goto label;
v = "Advisory";
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: java.lang.String getType()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = <org.apache.activemq.transport.stomp.Stomp$Transformations: org.apache.activemq.transport.stomp.Stomp$Transformations JMS_XML>;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.Stomp$Transformations: boolean equals(java.lang.String)>(v);
if v == 0 goto label;
v = <org.apache.activemq.transport.stomp.Stomp$Transformations: org.apache.activemq.transport.stomp.Stomp$Transformations JMS_ADVISORY_XML>;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.Stomp$Transformations: java.lang.String toString()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("transformation", v);
goto label;
label:
v = <org.apache.activemq.transport.stomp.Stomp$Transformations: org.apache.activemq.transport.stomp.Stomp$Transformations JMS_JSON>;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.Stomp$Transformations: boolean equals(java.lang.String)>(v);
if v == 0 goto label;
v = <org.apache.activemq.transport.stomp.Stomp$Transformations: org.apache.activemq.transport.stomp.Stomp$Transformations JMS_ADVISORY_JSON>;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.Stomp$Transformations: java.lang.String toString()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("transformation", v);
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("transformation");
if v != 0 goto label;
v = <org.apache.activemq.transport.stomp.Stomp$Transformations: org.apache.activemq.transport.stomp.Stomp$Transformations JMS_ADVISORY_JSON>;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.Stomp$Transformations: java.lang.String toString()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("transformation", v);
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.command.DataStructure getDataStructure()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("transformation");
v = virtualinvoke v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: java.lang.String marshallAdvisory(org.apache.activemq.command.DataStructure,java.lang.String)>(v, v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.lang.String)>("UTF-8");
virtualinvoke v.<org.apache.activemq.transport.stomp.StompFrame: void setContent(byte[])>(v);
goto label;
label:
v = specialinvoke v.<org.apache.activemq.transport.stomp.LegacyFrameTranslator: org.apache.activemq.transport.stomp.StompFrame convertMessage(org.apache.activemq.transport.stomp.ProtocolConverter,org.apache.activemq.command.ActiveMQMessage)>(v, v);
label:
return v;
}
protected java.lang.String marshall(java.io.Serializable, java.lang.String) throws javax.jms.JMSException
{
com.thoughtworks.xstream.XStream v;
java.io.StringWriter v;
org.apache.activemq.transport.stomp.JmsFrameTranslator v;
org.codehaus.jettison.mapped.Configuration v;
java.io.Serializable v;
com.thoughtworks.xstream.io.xml.PrettyPrintWriter v;
com.thoughtworks.xstream.io.json.JettisonMappedXmlDriver v;
java.util.Locale v;
java.lang.Object v;
java.lang.String v, v, v;
boolean v;
v := @this: org.apache.activemq.transport.stomp.JmsFrameTranslator;
v := @parameter: java.io.Serializable;
v := @parameter: java.lang.String;
v = new java.io.StringWriter;
specialinvoke v.<java.io.StringWriter: void <init>()>();
v = <java.util.Locale: java.util.Locale ENGLISH>;
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase(java.util.Locale)>(v);
v = virtualinvoke v.<java.lang.String: boolean endsWith(java.lang.String)>("json");
if v == 0 goto label;
v = new com.thoughtworks.xstream.io.json.JettisonMappedXmlDriver;
v = new org.codehaus.jettison.mapped.Configuration;
specialinvoke v.<org.codehaus.jettison.mapped.Configuration: void <init>()>();
specialinvoke v.<com.thoughtworks.xstream.io.json.JettisonMappedXmlDriver: void <init>(org.codehaus.jettison.mapped.Configuration,boolean)>(v, 0);
v = virtualinvoke v.<com.thoughtworks.xstream.io.json.JettisonMappedXmlDriver: com.thoughtworks.xstream.io.HierarchicalStreamWriter createWriter(java.io.Writer)>(v);
goto label;
label:
v = new com.thoughtworks.xstream.io.xml.PrettyPrintWriter;
specialinvoke v.<com.thoughtworks.xstream.io.xml.PrettyPrintWriter: void <init>(java.io.Writer)>(v);
v = v;
label:
v = virtualinvoke v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: com.thoughtworks.xstream.XStream getXStream()>();
virtualinvoke v.<com.thoughtworks.xstream.XStream: void marshal(java.lang.Object,com.thoughtworks.xstream.io.HierarchicalStreamWriter)>(v, v);
v = virtualinvoke v.<java.io.StringWriter: java.lang.String toString()>();
return v;
}
protected org.apache.activemq.command.ActiveMQObjectMessage createObjectMessage(com.thoughtworks.xstream.io.HierarchicalStreamReader) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQObjectMessage v;
com.thoughtworks.xstream.XStream v;
com.thoughtworks.xstream.io.HierarchicalStreamReader v;
java.lang.Object v;
org.apache.activemq.transport.stomp.JmsFrameTranslator v;
v := @this: org.apache.activemq.transport.stomp.JmsFrameTranslator;
v := @parameter: com.thoughtworks.xstream.io.HierarchicalStreamReader;
v = new org.apache.activemq.command.ActiveMQObjectMessage;
specialinvoke v.<org.apache.activemq.command.ActiveMQObjectMessage: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: com.thoughtworks.xstream.XStream getXStream()>();
v = virtualinvoke v.<com.thoughtworks.xstream.XStream: java.lang.Object unmarshal(com.thoughtworks.xstream.io.HierarchicalStreamReader)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQObjectMessage: void setObject(java.io.Serializable)>(v);
return v;
}
protected org.apache.activemq.command.ActiveMQMapMessage createMapMessage(com.thoughtworks.xstream.io.HierarchicalStreamReader) throws javax.jms.JMSException
{
com.thoughtworks.xstream.XStream v;
java.util.Iterator v;
org.apache.activemq.command.ActiveMQMapMessage v;
java.util.Set v;
org.apache.activemq.transport.stomp.JmsFrameTranslator v;
com.thoughtworks.xstream.io.HierarchicalStreamReader v;
java.lang.Object v, v, v;
boolean v;
v := @this: org.apache.activemq.transport.stomp.JmsFrameTranslator;
v := @parameter: com.thoughtworks.xstream.io.HierarchicalStreamReader;
v = new org.apache.activemq.command.ActiveMQMapMessage;
specialinvoke v.<org.apache.activemq.command.ActiveMQMapMessage: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: com.thoughtworks.xstream.XStream getXStream()>();
v = virtualinvoke v.<com.thoughtworks.xstream.XStream: java.lang.Object unmarshal(com.thoughtworks.xstream.io.HierarchicalStreamReader)>(v);
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
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: java.lang.Object get(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMapMessage: void setObject(java.lang.String,java.lang.Object)>(v, v);
goto label;
label:
return v;
}
protected java.lang.String marshallAdvisory(org.apache.activemq.command.DataStructure, java.lang.String)
{
com.thoughtworks.xstream.XStream v;
java.io.StringWriter v;
org.apache.activemq.transport.stomp.JmsFrameTranslator v;
com.thoughtworks.xstream.io.xml.PrettyPrintWriter v;
com.thoughtworks.xstream.io.json.JettisonMappedXmlDriver v;
java.util.Locale v;
org.apache.activemq.command.DataStructure v;
java.lang.Object v;
java.lang.String v, v, v;
boolean v;
v := @this: org.apache.activemq.transport.stomp.JmsFrameTranslator;
v := @parameter: org.apache.activemq.command.DataStructure;
v := @parameter: java.lang.String;
v = new java.io.StringWriter;
specialinvoke v.<java.io.StringWriter: void <init>()>();
v = <java.util.Locale: java.util.Locale ENGLISH>;
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase(java.util.Locale)>(v);
v = virtualinvoke v.<java.lang.String: boolean endsWith(java.lang.String)>("json");
if v == 0 goto label;
v = new com.thoughtworks.xstream.io.json.JettisonMappedXmlDriver;
specialinvoke v.<com.thoughtworks.xstream.io.json.JettisonMappedXmlDriver: void <init>()>();
v = virtualinvoke v.<com.thoughtworks.xstream.io.json.JettisonMappedXmlDriver: com.thoughtworks.xstream.io.HierarchicalStreamWriter createWriter(java.io.Writer)>(v);
goto label;
label:
v = new com.thoughtworks.xstream.io.xml.PrettyPrintWriter;
specialinvoke v.<com.thoughtworks.xstream.io.xml.PrettyPrintWriter: void <init>(java.io.Writer)>(v);
v = v;
label:
v = specialinvoke v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: com.thoughtworks.xstream.XStream getXStreamAdvisory()>();
virtualinvoke v.<com.thoughtworks.xstream.XStream: void setMode(int)>(1001);
virtualinvoke v.<com.thoughtworks.xstream.XStream: void aliasPackage(java.lang.String,java.lang.String)>("", "org.apache.activemq.command");
virtualinvoke v.<com.thoughtworks.xstream.XStream: void marshal(java.lang.Object,com.thoughtworks.xstream.io.HierarchicalStreamWriter)>(v, v);
v = virtualinvoke v.<java.io.StringWriter: java.lang.String toString()>();
return v;
}
private com.thoughtworks.xstream.XStream getXStreamAdvisory()
{
com.thoughtworks.xstream.XStream v, v, v;
org.apache.activemq.transport.stomp.JmsFrameTranslator v;
v := @this: org.apache.activemq.transport.stomp.JmsFrameTranslator;
v = v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: com.thoughtworks.xstream.XStream xStreamAdvisory>;
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: com.thoughtworks.xstream.XStream createXStream()>();
v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: com.thoughtworks.xstream.XStream xStreamAdvisory> = v;
label:
v = v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: com.thoughtworks.xstream.XStream xStreamAdvisory>;
return v;
}
public com.thoughtworks.xstream.XStream getXStream()
{
com.thoughtworks.xstream.XStream v, v, v;
org.apache.activemq.transport.stomp.JmsFrameTranslator v;
v := @this: org.apache.activemq.transport.stomp.JmsFrameTranslator;
v = v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: com.thoughtworks.xstream.XStream xStream>;
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: com.thoughtworks.xstream.XStream createXStream()>();
v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: com.thoughtworks.xstream.XStream xStream> = v;
label:
v = v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: com.thoughtworks.xstream.XStream xStream>;
return v;
}
public void setXStream(com.thoughtworks.xstream.XStream)
{
com.thoughtworks.xstream.XStream v;
org.apache.activemq.transport.stomp.JmsFrameTranslator v;
v := @this: org.apache.activemq.transport.stomp.JmsFrameTranslator;
v := @parameter: com.thoughtworks.xstream.XStream;
v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: com.thoughtworks.xstream.XStream xStream> = v;
return;
}
protected com.thoughtworks.xstream.XStream createXStream()
{
com.thoughtworks.xstream.XStream v;
java.util.Iterator v;
java.util.Collection v;
org.apache.activemq.broker.BrokerContext v, v;
org.apache.activemq.transport.stomp.JmsFrameTranslator v;
java.util.Map v;
java.lang.Object v;
boolean v;
org.apache.activemq.transport.stomp.JmsFrameTranslator$1 v;
v := @this: org.apache.activemq.transport.stomp.JmsFrameTranslator;
v = null;
v = v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: org.apache.activemq.broker.BrokerContext brokerContext>;
if v == null goto label;
v = v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: org.apache.activemq.broker.BrokerContext brokerContext>;
v = interfaceinvoke v.<org.apache.activemq.broker.BrokerContext: java.util.Map getBeansOfType(java.lang.Class)>(class "Lcom/thoughtworks/xstream/XStream;");
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: 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()>();
if v == null goto label;
v = v;
label:
if v != null goto label;
v = staticinvoke <org.apache.activemq.util.XStreamSupport: com.thoughtworks.xstream.XStream createXStream()>();
virtualinvoke v.<com.thoughtworks.xstream.XStream: void ignoreUnknownElements()>();
label:
v = new org.apache.activemq.transport.stomp.JmsFrameTranslator$1;
specialinvoke v.<org.apache.activemq.transport.stomp.JmsFrameTranslator$1: void <init>(org.apache.activemq.transport.stomp.JmsFrameTranslator)>(v);
virtualinvoke v.<com.thoughtworks.xstream.XStream: void registerConverter(com.thoughtworks.xstream.converters.SingleValueConverter)>(v);
virtualinvoke v.<com.thoughtworks.xstream.XStream: void alias(java.lang.String,java.lang.Class)>("string", class "Lorg/fusesource/hawtbuf/UTF8Buffer;");
return v;
}
public void setBrokerContext(org.apache.activemq.broker.BrokerContext)
{
org.apache.activemq.broker.BrokerContext v;
org.apache.activemq.transport.stomp.JmsFrameTranslator v;
v := @this: org.apache.activemq.transport.stomp.JmsFrameTranslator;
v := @parameter: org.apache.activemq.broker.BrokerContext;
v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: org.apache.activemq.broker.BrokerContext brokerContext> = v;
return;
}
public org.apache.activemq.broker.BrokerContext getBrokerContext()
{
org.apache.activemq.broker.BrokerContext v;
org.apache.activemq.transport.stomp.JmsFrameTranslator v;
v := @this: org.apache.activemq.transport.stomp.JmsFrameTranslator;
v = v.<org.apache.activemq.transport.stomp.JmsFrameTranslator: org.apache.activemq.broker.BrokerContext brokerContext>;
return v;
}
protected java.lang.String marshallAdvisory(org.apache.activemq.command.DataStructure)
{
com.thoughtworks.xstream.XStream v;
org.apache.activemq.command.DataStructure v;
java.lang.String v;
org.apache.activemq.transport.stomp.JmsFrameTranslator v;
com.thoughtworks.xstream.io.json.JsonHierarchicalStreamDriver v;
v := @this: org.apache.activemq.transport.stomp.JmsFrameTranslator;
v := @parameter: org.apache.activemq.command.DataStructure;
v = new com.thoughtworks.xstream.XStream;
v = new com.thoughtworks.xstream.io.json.JsonHierarchicalStreamDriver;
specialinvoke v.<com.thoughtworks.xstream.io.json.JsonHierarchicalStreamDriver: void <init>()>();
specialinvoke v.<com.thoughtworks.xstream.XStream: void <init>(com.thoughtworks.xstream.io.HierarchicalStreamDriver)>(v);
virtualinvoke v.<com.thoughtworks.xstream.XStream: void setMode(int)>(1001);
virtualinvoke v.<com.thoughtworks.xstream.XStream: void aliasPackage(java.lang.String,java.lang.String)>("", "org.apache.activemq.command");
v = virtualinvoke v.<com.thoughtworks.xstream.XStream: java.lang.String toXML(java.lang.Object)>(v);
return v;
}
}