public class org.apache.camel.component.jms.JmsMessage extends org.apache.camel.impl.DefaultMessage
{
private static final org.slf4j.Logger LOG;
private javax.jms.Message jmsMessage;
private javax.jms.Session jmsSession;
private org.apache.camel.component.jms.JmsBinding binding;
public void <init>(javax.jms.Message, org.apache.camel.component.jms.JmsBinding)
{
javax.jms.Message v;
org.apache.camel.component.jms.JmsBinding v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v := @parameter: javax.jms.Message;
v := @parameter: org.apache.camel.component.jms.JmsBinding;
specialinvoke v.<org.apache.camel.component.jms.JmsMessage: void <init>(javax.jms.Message,javax.jms.Session,org.apache.camel.component.jms.JmsBinding)>(v, null, v);
return;
}
public void <init>(javax.jms.Message, javax.jms.Session, org.apache.camel.component.jms.JmsBinding)
{
javax.jms.Session v;
javax.jms.Message v;
org.apache.camel.component.jms.JmsBinding v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v := @parameter: javax.jms.Message;
v := @parameter: javax.jms.Session;
v := @parameter: org.apache.camel.component.jms.JmsBinding;
specialinvoke v.<org.apache.camel.impl.DefaultMessage: void <init>()>();
virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: void setJmsMessage(javax.jms.Message)>(v);
virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: void setJmsSession(javax.jms.Session)>(v);
virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: void setBinding(org.apache.camel.component.jms.JmsBinding)>(v);
return;
}
public java.lang.String toString()
{
java.lang.Throwable v;
java.lang.String v, v, v, v;
javax.jms.Message v, v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v = v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage>;
if v == null goto label;
label:
v = v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage>;
v = interfaceinvoke v.<javax.jms.Message: java.lang.String getJMSMessageID()>();
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[])>("JmsMessage[JmsMessageID: \u]");
label:
return v;
label:
v := @caughtexception;
label:
v = staticinvoke <org.apache.camel.util.ObjectHelper: java.lang.String getIdentityHashCode(java.lang.Object)>(v);
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[])>("JmsMessage@\u0001");
return v;
catch java.lang.Throwable from label to label with label;
}
public void copyFrom(org.apache.camel.Message)
{
org.apache.camel.Message v;
org.apache.camel.Exchange v, v;
java.util.Map v, v, v, v, v, v;
java.lang.String v;
javax.jms.Message v, v;
boolean v, v, v, v, v;
org.apache.camel.component.jms.JmsMessage v;
java.lang.Object v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v := @parameter: org.apache.camel.Message;
if v != v goto label;
return;
label:
v = virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: java.util.Map getHeaders()>();
interfaceinvoke v.<java.util.Map: void clear()>();
v = 1;
v = v instanceof org.apache.camel.component.jms.JmsMessage;
if v == 0 goto label;
v = v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage>;
v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage> = v;
v = v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage>;
if v == null goto label;
v = 0;
label:
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.camel.Message: java.lang.String getMessageId()>();
virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: void setMessageId(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: org.apache.camel.Exchange getExchange()>();
if v != null goto label;
v = interfaceinvoke v.<org.apache.camel.Message: org.apache.camel.Exchange getExchange()>();
virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: void setExchange(org.apache.camel.Exchange)>(v);
label:
v = interfaceinvoke v.<org.apache.camel.Message: java.lang.Object getBody()>();
virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: void setBody(java.lang.Object)>(v);
v = interfaceinvoke v.<org.apache.camel.Message: boolean isFault()>();
virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: void setFault(boolean)>(v);
v = interfaceinvoke v.<org.apache.camel.Message: boolean hasHeaders()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: java.util.Map getHeaders()>();
v = interfaceinvoke v.<org.apache.camel.Message: java.util.Map getHeaders()>();
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: java.util.Map getAttachments()>();
interfaceinvoke v.<java.util.Map: void clear()>();
v = interfaceinvoke v.<org.apache.camel.Message: boolean hasAttachments()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: java.util.Map getAttachmentObjects()>();
v = interfaceinvoke v.<org.apache.camel.Message: java.util.Map getAttachmentObjects()>();
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
label:
return;
}
public org.apache.camel.component.jms.JmsBinding getBinding()
{
java.lang.Object v;
org.apache.camel.Exchange v;
org.apache.camel.component.jms.JmsBinding v, v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v = v.<org.apache.camel.component.jms.JmsMessage: org.apache.camel.component.jms.JmsBinding binding>;
if v != null goto label;
v = virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: org.apache.camel.Exchange getExchange()>();
v = staticinvoke <org.apache.camel.util.ExchangeHelper: java.lang.Object getBinding(org.apache.camel.Exchange,java.lang.Class)>(v, class "Lorg/apache/camel/component/jms/JmsBinding;");
v.<org.apache.camel.component.jms.JmsMessage: org.apache.camel.component.jms.JmsBinding binding> = v;
label:
v = v.<org.apache.camel.component.jms.JmsMessage: org.apache.camel.component.jms.JmsBinding binding>;
return v;
}
public void setBinding(org.apache.camel.component.jms.JmsBinding)
{
org.apache.camel.component.jms.JmsBinding v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v := @parameter: org.apache.camel.component.jms.JmsBinding;
v.<org.apache.camel.component.jms.JmsMessage: org.apache.camel.component.jms.JmsBinding binding> = v;
return;
}
public javax.jms.Message getJmsMessage()
{
javax.jms.Message v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v = v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage>;
return v;
}
public void setJmsMessage(javax.jms.Message)
{
org.slf4j.Logger v;
java.lang.String v;
javax.jms.JMSException v;
javax.jms.Message v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v := @parameter: javax.jms.Message;
if v == null goto label;
label:
v = interfaceinvoke v.<javax.jms.Message: java.lang.String getJMSMessageID()>();
virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: void setMessageId(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.camel.component.jms.JmsMessage: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Unable to retrieve JMSMessageID from JMS Message", v);
label:
v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage> = v;
return;
catch javax.jms.JMSException from label to label with label;
}
public javax.jms.Session getJmsSession()
{
javax.jms.Session v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v = v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Session jmsSession>;
return v;
}
public void setJmsSession(javax.jms.Session)
{
javax.jms.Session v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v := @parameter: javax.jms.Session;
v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Session jmsSession> = v;
return;
}
public void setBody(java.lang.Object)
{
java.lang.Object v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v := @parameter: java.lang.Object;
specialinvoke v.<org.apache.camel.impl.DefaultMessage: void setBody(java.lang.Object)>(v);
if v != null goto label;
virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: void ensureInitialHeaders()>();
v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage> = null;
label:
return;
}
public java.lang.Object getHeader(java.lang.String)
{
java.lang.Object v;
java.lang.String v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: void ensureInitialHeaders()>();
v = specialinvoke v.<org.apache.camel.impl.DefaultMessage: java.lang.Object getHeader(java.lang.String)>(v);
return v;
}
public java.util.Map getHeaders()
{
java.util.Map v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: void ensureInitialHeaders()>();
v = specialinvoke v.<org.apache.camel.impl.DefaultMessage: java.util.Map getHeaders()>();
return v;
}
public java.lang.Object removeHeader(java.lang.String)
{
java.lang.Object v;
java.lang.String v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: void ensureInitialHeaders()>();
v = specialinvoke v.<org.apache.camel.impl.DefaultMessage: java.lang.Object removeHeader(java.lang.String)>(v);
return v;
}
public void setHeaders(java.util.Map)
{
java.util.Map v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v := @parameter: java.util.Map;
virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: void ensureInitialHeaders()>();
specialinvoke v.<org.apache.camel.impl.DefaultMessage: void setHeaders(java.util.Map)>(v);
return;
}
public void setHeader(java.lang.String, java.lang.Object)
{
java.lang.Object v;
java.lang.String v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: void ensureInitialHeaders()>();
specialinvoke v.<org.apache.camel.impl.DefaultMessage: void setHeader(java.lang.String,java.lang.Object)>(v, v);
return;
}
public org.apache.camel.component.jms.JmsMessage newInstance()
{
org.apache.camel.CamelContext v;
org.apache.camel.component.jms.JmsBinding v;
org.apache.camel.component.jms.JmsMessage v, v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v = new org.apache.camel.component.jms.JmsMessage;
v = v.<org.apache.camel.component.jms.JmsMessage: org.apache.camel.component.jms.JmsBinding binding>;
specialinvoke v.<org.apache.camel.component.jms.JmsMessage: void <init>(javax.jms.Message,javax.jms.Session,org.apache.camel.component.jms.JmsBinding)>(null, null, v);
v = virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: org.apache.camel.CamelContext getCamelContext()>();
virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: void setCamelContext(org.apache.camel.CamelContext)>(v);
return v;
}
public boolean shouldCreateNewMessage()
{
boolean v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v = specialinvoke v.<org.apache.camel.impl.DefaultMessage: boolean hasPopulatedHeaders()>();
return v;
}
protected void ensureInitialHeaders()
{
java.util.Map v;
javax.jms.Message v;
boolean v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v = v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage>;
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: boolean hasPopulatedHeaders()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: java.util.Map createHeaders()>();
specialinvoke v.<org.apache.camel.impl.DefaultMessage: void setHeaders(java.util.Map)>(v);
label:
return;
}
protected java.lang.Object createBody()
{
java.lang.Object v;
org.apache.camel.Exchange v;
javax.jms.Message v, v;
org.apache.camel.component.jms.JmsBinding v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v = v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage>;
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: org.apache.camel.component.jms.JmsBinding getBinding()>();
v = virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: org.apache.camel.Exchange getExchange()>();
v = v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage>;
v = virtualinvoke v.<org.apache.camel.component.jms.JmsBinding: java.lang.Object extractBodyFromJms(org.apache.camel.Exchange,javax.jms.Message)>(v, v);
return v;
label:
return null;
}
protected void populateInitialHeaders(java.util.Map)
{
java.util.Map v, v;
org.apache.camel.Exchange v;
javax.jms.Message v, v;
org.apache.camel.component.jms.JmsBinding v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v := @parameter: java.util.Map;
v = v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage>;
if v == null goto label;
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: org.apache.camel.component.jms.JmsBinding getBinding()>();
v = v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage>;
v = virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: org.apache.camel.Exchange getExchange()>();
v = virtualinvoke v.<org.apache.camel.component.jms.JmsBinding: java.util.Map extractHeadersFromJms(javax.jms.Message,org.apache.camel.Exchange)>(v, v);
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
label:
return;
}
protected java.lang.String createMessageId()
{
org.slf4j.Logger v;
org.apache.camel.Exchange v;
javax.jms.JMSException v;
javax.jms.Destination v;
org.apache.camel.RuntimeExchangeException v;
java.lang.String v, v, v, v, v;
javax.jms.Message v, v, v, v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v = v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage>;
if v != null goto label;
v = <org.apache.camel.component.jms.JmsMessage: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String)>("No javax.jms.Message set so generating a new message id");
v = specialinvoke v.<org.apache.camel.impl.DefaultMessage: java.lang.String createMessageId()>();
return v;
label:
v = v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage>;
v = interfaceinvoke v.<javax.jms.Message: javax.jms.Destination getJMSDestination()>();
v = specialinvoke v.<org.apache.camel.component.jms.JmsMessage: java.lang.String getDestinationAsString(javax.jms.Destination)>(v);
if v == null goto label;
v = v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage>;
v = interfaceinvoke v.<javax.jms.Message: java.lang.String getJMSMessageID()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("\u0001\u0001");
goto label;
label:
v = v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage>;
v = interfaceinvoke v.<javax.jms.Message: java.lang.String getJMSMessageID()>();
label:
v = specialinvoke v.<org.apache.camel.component.jms.JmsMessage: java.lang.String getSanitizedString(java.lang.Object)>(v);
label:
return v;
label:
v := @caughtexception;
v = new org.apache.camel.RuntimeExchangeException;
v = virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: org.apache.camel.Exchange getExchange()>();
specialinvoke v.<org.apache.camel.RuntimeExchangeException: void <init>(java.lang.String,org.apache.camel.Exchange,java.lang.Throwable)>("Unable to retrieve JMSMessageID from JMS Message", v, v);
throw v;
catch javax.jms.JMSException from label to label with label;
}
protected java.lang.Boolean isTransactedRedelivered()
{
java.lang.Boolean v;
javax.jms.Message v, v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v = v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage>;
if v == null goto label;
v = v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message jmsMessage>;
v = staticinvoke <org.apache.camel.component.jms.JmsMessageHelper: java.lang.Boolean getJMSRedelivered(javax.jms.Message)>(v);
return v;
label:
return null;
}
private java.lang.String getDestinationAsString(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
java.lang.String v, v, v, v, v, v, v, v;
boolean v, v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v := @parameter: javax.jms.Destination;
v = null;
if v != null goto label;
v = <java.io.File: java.lang.String separator>;
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[])>("null destination!\u0001");
goto label;
label:
v = v instanceof javax.jms.Topic;
if v == 0 goto label;
v = <java.io.File: java.lang.String separator>;
v = interfaceinvoke v.<javax.jms.Topic: java.lang.String getTopicName()>();
v = <java.io.File: java.lang.String separator>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, 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[])>("topic\u0001\u0001\u0001");
goto label;
label:
v = v instanceof javax.jms.Queue;
if v == 0 goto label;
v = <java.io.File: java.lang.String separator>;
v = interfaceinvoke v.<javax.jms.Queue: java.lang.String getQueueName()>();
v = <java.io.File: java.lang.String separator>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, 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[])>("queue\u0001\u0001\u0001");
label:
return v;
}
private java.lang.String getSanitizedString(java.lang.Object)
{
java.lang.Object v;
java.lang.String v, v;
org.apache.camel.component.jms.JmsMessage v;
v := @this: org.apache.camel.component.jms.JmsMessage;
v := @parameter: java.lang.Object;
if v == null goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: java.lang.String replaceAll(java.lang.String,java.lang.String)>("[^a-zA-Z0-9\\.\\_\\-]", "_");
goto label;
label:
v = "";
label:
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/camel/component/jms/JmsMessage;");
<org.apache.camel.component.jms.JmsMessage: org.slf4j.Logger LOG> = v;
return;
}
}