public class org.springframework.jms.support.SimpleJmsHeaderMapper extends org.springframework.messaging.support.AbstractHeaderMapper implements org.springframework.jms.support.JmsHeaderMapper
{
private static final java.util.Set SUPPORTED_PROPERTY_TYPES;
public void <init>()
{
org.springframework.jms.support.SimpleJmsHeaderMapper v;
v := @this: org.springframework.jms.support.SimpleJmsHeaderMapper;
specialinvoke v.<org.springframework.messaging.support.AbstractHeaderMapper: void <init>()>();
return;
}
public void fromHeaders(org.springframework.messaging.MessageHeaders, javax.jms.Message)
{
boolean v, v, v, v, v, v, v, v, v, v;
org.springframework.jms.support.SimpleJmsHeaderMapper v;
java.util.Set v, v;
java.lang.Exception v, v, v, v, v;
java.lang.String v, v, v;
javax.jms.Message v;
java.util.Iterator v;
org.springframework.messaging.MessageHeaders v;
java.lang.Class v;
java.lang.Object v, v, v, v, v;
org.apache.commons.logging.Log v, v, v, v, v, v, v, v, v;
v := @this: org.springframework.jms.support.SimpleJmsHeaderMapper;
v := @parameter: org.springframework.messaging.MessageHeaders;
v := @parameter: javax.jms.Message;
label:
v = virtualinvoke v.<org.springframework.messaging.MessageHeaders: java.lang.Object get(java.lang.Object)>("jms_correlationId");
v = v instanceof java.lang.Number;
if v == 0 goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
label:
v = v instanceof java.lang.String;
if v == 0 goto label;
label:
interfaceinvoke v.<javax.jms.Message: void setJMSCorrelationID(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object,java.lang.Throwable)>("Failed to set JMSCorrelationID - skipping", v);
label:
v = virtualinvoke v.<org.springframework.jms.support.SimpleJmsHeaderMapper: java.lang.Object getHeaderIfAvailable(java.util.Map,java.lang.String,java.lang.Class)>(v, "jms_replyTo", class "Ljavax/jms/Destination;");
if v == null goto label;
label:
interfaceinvoke v.<javax.jms.Message: void setJMSReplyTo(javax.jms.Destination)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object,java.lang.Throwable)>("Failed to set JMSReplyTo - skipping", v);
label:
v = virtualinvoke v.<org.springframework.jms.support.SimpleJmsHeaderMapper: java.lang.Object getHeaderIfAvailable(java.util.Map,java.lang.String,java.lang.Class)>(v, "jms_type", class "Ljava/lang/String;");
if v == null goto label;
label:
interfaceinvoke v.<javax.jms.Message: void setJMSType(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object,java.lang.Throwable)>("Failed to set JMSType - skipping", v);
label:
v = virtualinvoke v.<org.springframework.messaging.MessageHeaders: 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 = staticinvoke <org.springframework.util.StringUtils: boolean hasText(java.lang.String)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("jms_");
if v != 0 goto label;
v = virtualinvoke v.<org.springframework.messaging.MessageHeaders: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = <org.springframework.jms.support.SimpleJmsHeaderMapper: java.util.Set SUPPORTED_PROPERTY_TYPES>;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = virtualinvoke v.<org.springframework.jms.support.SimpleJmsHeaderMapper: java.lang.String fromHeaderName(java.lang.String)>(v);
interfaceinvoke v.<javax.jms.Message: void setObjectProperty(java.lang.String,java.lang.Object)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("JMSX");
if v == 0 goto label;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
v = interfaceinvoke v.<org.apache.commons.logging.Log: boolean isTraceEnabled()>();
if v == 0 goto label;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
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[])>("Skipping reserved header \'\u0001\' since it cannot be set by client");
interfaceinvoke v.<org.apache.commons.logging.Log: void trace(java.lang.Object)>(v);
goto label;
label:
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
v = interfaceinvoke v.<org.apache.commons.logging.Log: boolean isWarnEnabled()>();
if v == 0 goto label;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
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[])>("Failed to map message header \'\u0001\' to JMS property");
interfaceinvoke v.<org.apache.commons.logging.Log: void warn(java.lang.Object,java.lang.Throwable)>(v, v);
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
v = interfaceinvoke v.<org.apache.commons.logging.Log: boolean isWarnEnabled()>();
if v == 0 goto label;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
interfaceinvoke v.<org.apache.commons.logging.Log: void warn(java.lang.Object,java.lang.Throwable)>("Error occurred while mapping from MessageHeaders to JMS properties", v);
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
public org.springframework.messaging.MessageHeaders toHeaders(javax.jms.Message)
{
java.util.Enumeration v;
java.lang.Integer v, v;
java.lang.Long v, v;
boolean v, v, v, v;
org.springframework.jms.support.SimpleJmsHeaderMapper v;
javax.jms.JMSException v;
java.lang.Exception v, v, v, v, v, v, v, v, v, v, v;
javax.jms.Destination v, v;
java.util.HashMap v;
long v, v;
int v, v;
java.lang.Boolean v;
java.lang.String v, v, v, v, v, v;
javax.jms.Message v;
org.springframework.messaging.MessageHeaders v;
java.lang.Object v, v;
org.apache.commons.logging.Log v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.springframework.jms.support.SimpleJmsHeaderMapper;
v := @parameter: javax.jms.Message;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
label:
v = interfaceinvoke v.<javax.jms.Message: java.lang.String getJMSCorrelationID()>();
if v == null goto label;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("jms_correlationId", v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object,java.lang.Throwable)>("Failed to read JMSCorrelationID property - skipping", v);
label:
v = interfaceinvoke v.<javax.jms.Message: javax.jms.Destination getJMSDestination()>();
if v == null goto label;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("jms_destination", v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object,java.lang.Throwable)>("Failed to read JMSDestination property - skipping", v);
label:
v = interfaceinvoke v.<javax.jms.Message: int getJMSDeliveryMode()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("jms_deliveryMode", v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object,java.lang.Throwable)>("Failed to read JMSDeliveryMode property - skipping", v);
label:
v = interfaceinvoke v.<javax.jms.Message: long getJMSExpiration()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("jms_expiration", v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object,java.lang.Throwable)>("Failed to read JMSExpiration property - skipping", v);
label:
v = interfaceinvoke v.<javax.jms.Message: java.lang.String getJMSMessageID()>();
if v == null goto label;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("jms_messageId", v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object,java.lang.Throwable)>("Failed to read JMSMessageID property - skipping", v);
label:
v = interfaceinvoke v.<javax.jms.Message: int getJMSPriority()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("jms_priority", v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object,java.lang.Throwable)>("Failed to read JMSPriority property - skipping", v);
label:
v = interfaceinvoke v.<javax.jms.Message: javax.jms.Destination getJMSReplyTo()>();
if v == null goto label;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("jms_replyTo", v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object,java.lang.Throwable)>("Failed to read JMSReplyTo property - skipping", v);
label:
v = interfaceinvoke v.<javax.jms.Message: boolean getJMSRedelivered()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("jms_redelivered", v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object,java.lang.Throwable)>("Failed to read JMSRedelivered property - skipping", v);
label:
v = interfaceinvoke v.<javax.jms.Message: java.lang.String getJMSType()>();
if v == null goto label;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("jms_type", v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object,java.lang.Throwable)>("Failed to read JMSType property - skipping", v);
label:
v = interfaceinvoke v.<javax.jms.Message: long getJMSTimestamp()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("jms_timestamp", v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object,java.lang.Throwable)>("Failed to read JMSTimestamp property - skipping", v);
label:
v = interfaceinvoke v.<javax.jms.Message: java.util.Enumeration getPropertyNames()>();
if v == null goto label;
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()>();
label:
v = virtualinvoke v.<org.springframework.jms.support.SimpleJmsHeaderMapper: java.lang.String toHeaderName(java.lang.String)>(v);
v = interfaceinvoke v.<javax.jms.Message: java.lang.Object getObjectProperty(java.lang.String)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
v = interfaceinvoke v.<org.apache.commons.logging.Log: boolean isWarnEnabled()>();
if v == 0 goto label;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
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[])>("Error occurred while mapping JMS property \'\u0001\' to Message header");
interfaceinvoke v.<org.apache.commons.logging.Log: void warn(java.lang.Object,java.lang.Throwable)>(v, v);
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
v = interfaceinvoke v.<org.apache.commons.logging.Log: boolean isWarnEnabled()>();
if v == 0 goto label;
v = v.<org.springframework.jms.support.SimpleJmsHeaderMapper: org.apache.commons.logging.Log logger>;
interfaceinvoke v.<org.apache.commons.logging.Log: void warn(java.lang.Object,java.lang.Throwable)>("Error occurred while mapping from JMS properties to MessageHeaders", v);
label:
v = new org.springframework.messaging.MessageHeaders;
specialinvoke v.<org.springframework.messaging.MessageHeaders: void <init>(java.util.Map)>(v);
return v;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch javax.jms.JMSException from label to label with label;
}
protected java.lang.String fromHeaderName(java.lang.String)
{
org.springframework.jms.support.SimpleJmsHeaderMapper v;
java.lang.String v, v, v;
boolean v;
v := @this: org.springframework.jms.support.SimpleJmsHeaderMapper;
v := @parameter: java.lang.String;
v = "contentType";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
return "content_type";
label:
v = specialinvoke v.<org.springframework.messaging.support.AbstractHeaderMapper: java.lang.String fromHeaderName(java.lang.String)>(v);
return v;
}
protected java.lang.String toHeaderName(java.lang.String)
{
org.springframework.jms.support.SimpleJmsHeaderMapper v;
java.lang.String v, v, v;
boolean v;
v := @this: org.springframework.jms.support.SimpleJmsHeaderMapper;
v := @parameter: java.lang.String;
v = "content_type";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
return "contentType";
label:
v = specialinvoke v.<org.springframework.messaging.support.AbstractHeaderMapper: java.lang.String toHeaderName(java.lang.String)>(v);
return v;
}
static void <clinit>()
{
java.util.HashSet v;
java.lang.Class[] v;
java.util.List v;
v = new java.util.HashSet;
v = newarray (java.lang.Class)[8];
v[0] = class "Ljava/lang/Boolean;";
v[1] = class "Ljava/lang/Byte;";
v[2] = class "Ljava/lang/Double;";
v[3] = class "Ljava/lang/Float;";
v[4] = class "Ljava/lang/Integer;";
v[5] = class "Ljava/lang/Long;";
v[6] = class "Ljava/lang/Short;";
v[7] = class "Ljava/lang/String;";
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
<org.springframework.jms.support.SimpleJmsHeaderMapper: java.util.Set SUPPORTED_PROPERTY_TYPES> = v;
return;
}
}