public class org.apache.camel.component.jms.JmsBinding extends java.lang.Object { private static final org.slf4j.Logger LOG; private final org.apache.camel.component.jms.JmsEndpoint endpoint; private final org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy; private final org.apache.camel.component.jms.JmsKeyFormatStrategy jmsKeyFormatStrategy; private final org.apache.camel.component.jms.MessageCreatedStrategy messageCreatedStrategy; public void () { org.apache.camel.component.jms.JmsHeaderFilterStrategy v; org.apache.camel.component.jms.DefaultJmsKeyFormatStrategy v; org.apache.camel.component.jms.JmsBinding v; v := @this: org.apache.camel.component.jms.JmsBinding; specialinvoke v.()>(); v. = null; v = new org.apache.camel.component.jms.JmsHeaderFilterStrategy; specialinvoke v.(boolean)>(0); v. = v; v = new org.apache.camel.component.jms.DefaultJmsKeyFormatStrategy; specialinvoke v.()>(); v. = v; v. = null; return; } public void (org.apache.camel.component.jms.JmsEndpoint) { org.apache.camel.component.jms.JmsHeaderFilterStrategy v; org.apache.camel.component.jms.JmsEndpoint v; org.apache.camel.component.jms.MessageCreatedStrategy v, v, v; org.apache.camel.component.jms.JmsKeyFormatStrategy v, v; org.apache.camel.spi.HeaderFilterStrategy v, v; org.apache.camel.component.jms.JmsComponent v, v; org.apache.camel.component.jms.DefaultJmsKeyFormatStrategy v; org.apache.camel.component.jms.JmsBinding v; boolean v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: org.apache.camel.component.jms.JmsEndpoint; specialinvoke v.()>(); v. = v; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v. = v; goto label; label: v = new org.apache.camel.component.jms.JmsHeaderFilterStrategy; v = virtualinvoke v.(); specialinvoke v.(boolean)>(v); v. = v; label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v. = v; goto label; label: v = new org.apache.camel.component.jms.DefaultJmsKeyFormatStrategy; specialinvoke v.()>(); v. = v; label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v. = v; goto label; label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v. = v; goto label; label: v. = null; label: return; } public java.lang.Object extractBodyFromJms(org.apache.camel.Exchange, javax.jms.Message) { org.apache.camel.Message v, v; java.util.Map v, v, v; boolean v, v, v, v, v, v, v, v; org.apache.camel.RuntimeCamelException v; javax.jms.JMSException v; java.io.Serializable v, v; org.springframework.jms.support.converter.MessageConverter v, v, v; org.apache.camel.component.jms.JmsBinding v; org.apache.camel.component.jms.JmsEndpoint v, v, v, v, v, v; org.apache.camel.Exchange v; java.lang.String v, v; javax.jms.Message v; org.slf4j.Logger v, v, v, v, v, v, v, v; org.apache.camel.component.jms.JmsConfiguration v; java.lang.Object v, v, v, v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: org.apache.camel.Exchange; v := @parameter: javax.jms.Message; label: v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == null goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = virtualinvoke v.(); interfaceinvoke v.("Extracting body using a custom MessageConverter: {} from JMS message: {}", v, v); label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); label: return v; label: v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = ; interfaceinvoke v.("Option map JMS message is false so using JMS message as body: {}", v); label: return v; label: v = v instanceof javax.jms.ObjectMessage; if v == 0 goto label; v = ; interfaceinvoke v.("Extracting body as a ObjectMessage from JMS message: {}", v); v = interfaceinvoke v.(); v = v instanceof org.apache.camel.impl.DefaultExchangeHolder; if v == 0 goto label; staticinvoke (v, v); v = virtualinvoke v.(v, v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: return v; label: v = interfaceinvoke v.(); label: return v; label: v = v instanceof javax.jms.TextMessage; if v == 0 goto label; v = ; interfaceinvoke v.("Extracting body as a TextMessage from JMS message: {}", v); v = interfaceinvoke v.(); label: return v; label: v = v instanceof javax.jms.MapMessage; if v == 0 goto label; v = ; interfaceinvoke v.("Extracting body as a MapMessage from JMS message: {}", v); v = virtualinvoke v.(v); label: return v; label: v = v instanceof javax.jms.BytesMessage; if v == 0 goto label; v = ; interfaceinvoke v.("Extracting body as a BytesMessage from JMS message: {}", v); v = virtualinvoke v.(v, v); label: return v; label: v = v instanceof javax.jms.StreamMessage; if v == 0 goto label; v = ; interfaceinvoke v.("Extracting body as a StreamMessage from JMS message: {}", v); v = virtualinvoke v.(v, v); label: return v; label: return null; label: v := @caughtexception; v = new org.apache.camel.RuntimeCamelException; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Failed to extract body due to: \u. Message: \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; catch javax.jms.JMSException from label to label with label; catch javax.jms.JMSException from label to label with label; catch javax.jms.JMSException from label to label with label; catch javax.jms.JMSException from label to label with label; catch javax.jms.JMSException from label to label with label; catch javax.jms.JMSException from label to label with label; catch javax.jms.JMSException from label to label with label; catch javax.jms.JMSException from label to label with label; } public java.util.Map extractHeadersFromJms(javax.jms.Message, org.apache.camel.Exchange) { java.util.Enumeration v; java.lang.Integer v, v; java.lang.Long v, v; boolean v, v, v; org.apache.camel.RuntimeCamelException v, v, v; org.apache.camel.spi.HeaderFilterStrategy v, v; javax.jms.JMSException v, v, v; javax.jms.Destination v, v; org.apache.camel.component.jms.JmsBinding v; java.util.HashMap v; long v, v; org.apache.camel.Exchange v; int v, v; java.lang.Boolean v; java.lang.String v, v, v, v, v, v, v, v; javax.jms.Message v; org.apache.camel.component.jms.JmsKeyFormatStrategy v; java.lang.Object v, v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: javax.jms.Message; v := @parameter: org.apache.camel.Exchange; v = new java.util.HashMap; specialinvoke v.()>(); if v == null goto label; label: v = interfaceinvoke v.(); interfaceinvoke v.("JMSCorrelationID", v); v = staticinvoke (v); interfaceinvoke v.("JMSCorrelationIDAsBytes", v); v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("JMSDeliveryMode", v); v = interfaceinvoke v.(); interfaceinvoke v.("JMSDestination", v); v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("JMSExpiration", v); v = interfaceinvoke v.(); interfaceinvoke v.("JMSMessageID", v); v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("JMSPriority", v); v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("JMSRedelivered", v); v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("JMSTimestamp", v); v = staticinvoke (v); interfaceinvoke v.("JMSReplyTo", v); v = staticinvoke (v); interfaceinvoke v.("JMSType", v); v = staticinvoke (v, "JMSXGroupID"); interfaceinvoke v.("JMSXGroupID", v); v = staticinvoke (v, "JMSXUserID"); interfaceinvoke v.("JMSXUserID", v); label: goto label; label: v := @caughtexception; v = new org.apache.camel.RuntimeCamelException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = new org.apache.camel.RuntimeCamelException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); label: v = staticinvoke (v, v); v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(v, v, v); if v != 0 goto label; label: v = v.; v = interfaceinvoke v.(v); interfaceinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = new org.apache.camel.RuntimeCamelException; specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: return v; catch javax.jms.JMSException from label to label with label; catch javax.jms.JMSException from label to label with label; catch javax.jms.JMSException from label to label with label; catch javax.jms.JMSException from label to label with label; } public java.lang.Object getObjectProperty(javax.jms.Message, java.lang.String) throws javax.jms.JMSException { org.apache.camel.component.jms.JmsKeyFormatStrategy v; java.lang.Object v; java.lang.String v, v; javax.jms.Message v; org.apache.camel.component.jms.JmsBinding v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: javax.jms.Message; v := @parameter: java.lang.String; v = interfaceinvoke v.(v); if v != null goto label; v = v.; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); label: return v; } protected java.lang.Object createByteArrayFromBytesMessage(org.apache.camel.Exchange, javax.jms.BytesMessage) throws javax.jms.JMSException { java.lang.Throwable v; byte[] v; long v, v, v, v; org.apache.camel.Exchange v; byte v, v; java.lang.Long v, v; java.lang.String v; org.slf4j.Logger v, v; java.io.IOException v; javax.jms.BytesMessage v; org.apache.camel.converter.stream.CachedOutputStream v; javax.jms.MessageFormatException v; org.apache.camel.component.jms.JmsBinding v; java.io.InputStream v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: org.apache.camel.Exchange; v := @parameter: javax.jms.BytesMessage; v = staticinvoke (v, "_AMQ_LARGE_SIZE"); if v == null goto label; v = virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = ; interfaceinvoke v.("Optimised for Artemis: Reading from BytesMessage in streaming mode directly into CachedOutputStream payload"); v = new org.apache.camel.converter.stream.CachedOutputStream; specialinvoke v.(org.apache.camel.Exchange,boolean)>(v, 1); interfaceinvoke v.("JMS_AMQ_SaveStream", v); label: v = virtualinvoke v.(); label: staticinvoke (v); return v; label: v := @caughtexception; v = new javax.jms.MessageFormatException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); throw v; label: v := @caughtexception; staticinvoke (v); throw v; label: v = interfaceinvoke v.(); v = v cmp 2147483647L; if v <= 0 goto label; v = ; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Length of BytesMessage is too long: {}", v); return null; label: v = interfaceinvoke v.(); v = newarray (byte)[v]; interfaceinvoke v.(v); return v; catch java.io.IOException from label to label with label; catch java.lang.Throwable from label to label with label; } protected java.lang.Object createInputStreamFromStreamMessage(org.apache.camel.Exchange, javax.jms.StreamMessage) throws javax.jms.JMSException { javax.jms.StreamMessage v; org.apache.camel.component.jms.StreamMessageInputStream v; org.apache.camel.Exchange v; org.apache.camel.component.jms.JmsBinding v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: org.apache.camel.Exchange; v := @parameter: javax.jms.StreamMessage; v = new org.apache.camel.component.jms.StreamMessageInputStream; specialinvoke v.(javax.jms.StreamMessage)>(v); return v; } public javax.jms.Message makeJmsMessage(org.apache.camel.Exchange, javax.jms.Session) throws javax.jms.JMSException { javax.jms.Session v; org.apache.camel.component.jms.MessageCreatedStrategy v, v; org.apache.camel.Message v; org.apache.camel.Exchange v; javax.jms.Message v; org.apache.camel.component.jms.JmsBinding v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: org.apache.camel.Exchange; v := @parameter: javax.jms.Session; v = interfaceinvoke v.(); v = virtualinvoke v.(v, v, v, null); if v == null goto label; v = v.; if v == null goto label; v = v.; interfaceinvoke v.(v, v, v, null); label: return v; } public javax.jms.Message makeJmsMessage(org.apache.camel.Exchange, org.apache.camel.Message, javax.jms.Session, java.lang.Exception) throws javax.jms.JMSException { org.apache.camel.component.jms.MessageCreatedStrategy v, v; org.apache.camel.Message v; javax.jms.Session v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Exception v; org.apache.camel.component.jms.JmsBinding v; org.apache.camel.component.jms.JmsEndpoint v, v, v, v, v, v; org.apache.camel.Exchange v; org.apache.camel.component.jms.JmsMessageType v, v, v, v, v, v; javax.jms.Message v, v, v, v, v, v; org.apache.camel.CamelContext v; org.slf4j.Logger v; org.apache.camel.component.jms.JmsConfiguration v, v, v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: org.apache.camel.Exchange; v := @parameter: org.apache.camel.Message; v := @parameter: javax.jms.Session; v := @parameter: java.lang.Exception; v = null; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = 1; goto label; label: v = 0; label: v = v; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = 1; goto label; label: v = 0; label: v = v; if v != 0 goto label; v = v instanceof org.apache.camel.component.jms.JmsMessage; if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; if v == 0 goto label; label: v = virtualinvoke v.(); if v != 0 goto label; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); goto label; label: v = null; label: if v == null goto label; if v == null goto label; v = ; if v != v goto label; v = v instanceof javax.jms.TextMessage; if v == 0 goto label; v = v; goto label; label: v = null; label: v = v; goto label; label: v = ; if v != v goto label; v = v instanceof javax.jms.BytesMessage; if v == 0 goto label; v = v; goto label; label: v = null; label: v = v; goto label; label: v = ; if v != v goto label; v = v instanceof javax.jms.MapMessage; if v == 0 goto label; v = v; goto label; label: v = null; label: v = v; goto label; label: v = ; if v != v goto label; v = v instanceof javax.jms.ObjectMessage; if v == 0 goto label; v = v; goto label; label: v = null; label: v = v; goto label; label: v = ; if v != v goto label; v = v instanceof javax.jms.StreamMessage; if v == 0 goto label; v = v; goto label; label: v = null; label: v = v; label: if v != null goto label; if v == null goto label; v = ; interfaceinvoke v.("Will create JmsMessage with caused exception: {}", v); v = virtualinvoke v.(v, v); goto label; label: staticinvoke (v, "message"); v = interfaceinvoke v.(); v = virtualinvoke v.(v, v, v, v); virtualinvoke v.(v, v, v); label: if v == null goto label; v = v.; if v == null goto label; v = v.; interfaceinvoke v.(v, v, v, null); label: return v; } public void appendJmsProperties(javax.jms.Message, org.apache.camel.Exchange) throws javax.jms.JMSException { org.apache.camel.Message v; org.apache.camel.Exchange v; javax.jms.Message v; org.apache.camel.component.jms.JmsBinding v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: javax.jms.Message; v := @parameter: org.apache.camel.Exchange; v = interfaceinvoke v.(); virtualinvoke v.(v, v, v); return; } public void appendJmsProperties(javax.jms.Message, org.apache.camel.Exchange, org.apache.camel.Message) throws javax.jms.JMSException { java.util.Iterator v; org.apache.camel.Message v; java.util.Set v; org.apache.camel.Exchange v; java.util.Map v; java.lang.Object v, v, v; javax.jms.Message v; org.apache.camel.component.jms.JmsBinding v; boolean v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: javax.jms.Message; v := @parameter: org.apache.camel.Exchange; v := @parameter: org.apache.camel.Message; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); virtualinvoke v.(v, v, v, v, v); goto label; label: return; } public void appendJmsProperty(javax.jms.Message, org.apache.camel.Exchange, org.apache.camel.Message, java.lang.String, java.lang.Object) throws javax.jms.JMSException { org.apache.camel.Message v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.camel.component.jms.JmsBinding v; org.apache.camel.component.jms.JmsEndpoint v, v, v, v; java.lang.Object[] v; long v; org.apache.camel.Exchange v; int v; java.lang.String v, v, v, v, v; javax.jms.Message v; org.slf4j.Logger v, v, v, v; java.util.Iterator v; org.apache.camel.component.jms.JmsConfiguration v, v; org.apache.camel.component.jms.JmsKeyFormatStrategy v; java.lang.Class v; java.lang.Object v, v, v, v, v, v, v, v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: javax.jms.Message; v := @parameter: org.apache.camel.Exchange; v := @parameter: org.apache.camel.Message; v := @parameter: java.lang.String; v := @parameter: java.lang.Object; v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.("JMSCorrelationID"); if v == 0 goto label; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; label: v = staticinvoke (v, class "Ljava/lang/String;", v); interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.("JMSReplyTo"); if v == 0 goto label; if v == null goto label; v = v instanceof java.lang.String; if v == 0 goto label; v = staticinvoke (v, 1); label: v = staticinvoke (v, class "Ljavax/jms/Destination;", v); staticinvoke (v, v); goto label; label: v = virtualinvoke v.("JMSType"); if v == 0 goto label; v = staticinvoke (v, class "Ljava/lang/String;", v); interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.("JMSPriority"); if v == 0 goto label; v = staticinvoke (v, class "Ljava/lang/Integer;", v); v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.("JMSDeliveryMode"); if v == 0 goto label; staticinvoke (v, v, v); goto label; label: v = virtualinvoke v.("JMSExpiration"); if v == 0 goto label; v = staticinvoke (v, class "Ljava/lang/Long;", v); v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: v = ; interfaceinvoke v.("Ignoring JMS header: {} with value: {}", v, v); goto label; label: v = virtualinvoke v.(v, v, v, v); if v == 0 goto label; v = virtualinvoke v.(v, v); if v != null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (v, v); if v == 0 goto label; v = ; interfaceinvoke v.("Header {} allowed as additional header despite not being valid according to the JMS specification", v); v = v; label: if v == null goto label; v = v.; v = interfaceinvoke v.(v); staticinvoke (v, v, v); goto label; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v[1] = v; v[2] = v; interfaceinvoke v.("Ignoring non primitive header: {} of class: {} with value: {}", v); label: return; } protected boolean isStandardJMSHeader(java.lang.String) { char v, v; java.lang.Character v; int v; java.lang.String v; org.apache.camel.component.jms.JmsBinding v; boolean v, v, v, v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: java.lang.String; v = virtualinvoke v.("JMS"); if v != 0 goto label; return 0; label: v = virtualinvoke v.("JMSX"); if v == 0 goto label; return 0; label: v = virtualinvoke v.("JMS_"); if v == 0 goto label; return 0; label: v = virtualinvoke v.(); if v <= 3 goto label; v = virtualinvoke v.(3); v = staticinvoke (v); v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; return 1; label: return 0; } protected java.lang.Object getValidJMSHeaderValue(java.lang.String, java.lang.Object) { org.apache.camel.component.jms.JmsEndpoint v; java.time.ZonedDateTime v; java.lang.String v, v, v, v, v, v; java.time.ZoneOffset v; boolean v, v, v, v, v, v, v, v, v; org.apache.camel.component.jms.JmsConfiguration v; java.time.Instant v; java.lang.Object v; org.apache.camel.component.jms.JmsBinding v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: java.lang.String; v := @parameter: java.lang.Object; v = v instanceof java.lang.String; if v == 0 goto label; return v; label: v = v instanceof java.math.BigInteger; if v == 0 goto label; v = virtualinvoke v.(); return v; label: v = v instanceof java.math.BigDecimal; if v == 0 goto label; v = virtualinvoke v.(); return v; label: v = v instanceof java.lang.Number; if v == 0 goto label; return v; label: v = v instanceof java.lang.Character; if v == 0 goto label; return v; label: v = v instanceof java.lang.CharSequence; if v == 0 goto label; v = virtualinvoke v.(); return v; label: v = v instanceof java.lang.Boolean; if v == 0 goto label; return v; label: v = v instanceof java.util.Date; if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = ; v = staticinvoke (v, v); v = virtualinvoke v.(); return v; label: v = virtualinvoke v.(); return v; label: return null; } protected javax.jms.Message createJmsMessage(java.lang.Exception, javax.jms.Session) throws javax.jms.JMSException { javax.jms.Session v; org.slf4j.Logger v; org.apache.camel.component.jms.JmsMessageType v; javax.jms.ObjectMessage v; java.lang.Exception v; org.apache.camel.component.jms.JmsBinding v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: java.lang.Exception; v := @parameter: javax.jms.Session; v = ; v = ; interfaceinvoke v.("Using JmsMessageType: {}", v); v = interfaceinvoke v.(v); interfaceinvoke v.(2); return v; } protected javax.jms.Message createJmsMessage(org.apache.camel.Exchange, org.apache.camel.Message, javax.jms.Session, org.apache.camel.CamelContext) throws javax.jms.JMSException { org.apache.camel.CamelContext v; org.apache.camel.component.jms.JmsEndpoint v, v; org.apache.camel.Message v; org.apache.camel.Exchange v; javax.jms.Session v; java.util.Map v; java.lang.Object v; javax.jms.Message v; org.apache.camel.component.jms.JmsBinding v; boolean v, v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: org.apache.camel.Exchange; v := @parameter: org.apache.camel.Message; v := @parameter: javax.jms.Session; v := @parameter: org.apache.camel.CamelContext; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(v, v, v, v, v); v = interfaceinvoke v.(); if v == null goto label; if v == 0 goto label; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; interfaceinvoke v.("CamelJmsTransferFault", 1); label: return v; } protected javax.jms.Message createJmsMessage(org.apache.camel.Exchange, java.lang.Object, java.util.Map, javax.jms.Session, org.apache.camel.CamelContext) throws javax.jms.JMSException { javax.jms.Session v; java.util.Map v; boolean v, v, v, v, v, v, v; javax.jms.JMSException v, v; org.apache.camel.impl.DefaultExchangeHolder v; org.springframework.jms.support.converter.MessageConverter v, v, v; org.apache.camel.component.jms.JmsBinding v; org.apache.camel.component.jms.JmsEndpoint v, v, v, v, v, v, v, v, v, v, v, v, v, v; javax.jms.ObjectMessage v; org.apache.camel.Exchange v; org.apache.camel.component.jms.JmsMessageType v; java.lang.String v, v; javax.jms.Message v, v, v; org.apache.camel.CamelContext v; org.slf4j.Logger v, v, v, v, v, v; org.apache.camel.component.jms.JmsConfiguration v, v, v, v; org.apache.camel.TypeConverter v; java.lang.Object v, v, v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: org.apache.camel.Exchange; v := @parameter: java.lang.Object; v := @parameter: java.util.Map; v := @parameter: javax.jms.Session; v := @parameter: org.apache.camel.CamelContext; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("Option transferExchange=true so we use JmsMessageType: Object"); v = v.; v = virtualinvoke v.(); v = staticinvoke (v, 1, v); v = interfaceinvoke v.(v); interfaceinvoke v.(2); return v; label: v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == null goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = virtualinvoke v.(); interfaceinvoke v.("Creating JmsMessage using a custom MessageConverter: {} with body: {}", v, v); label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v, v); return v; label: v = interfaceinvoke v.("CamelJmsMessageType"); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.("CamelJmsMessageType"); v = interfaceinvoke v.(class "Lorg/apache/camel/component/jms/JmsMessageType;", v); goto label; label: v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(v, v, v, v, v); label: if v == null goto label; if v != null goto label; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = new javax.jms.JMSException; specialinvoke v.(java.lang.String)>("Cannot send message as message body is null, and option allowNullBody is false."); throw v; label: v = ; interfaceinvoke v.("Using JmsMessageType: {}", v); v = virtualinvoke v.(v, v, v, v, v, v); interfaceinvoke v.(2); return v; label: if v != null goto label; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = new javax.jms.JMSException; specialinvoke v.(java.lang.String)>("Cannot send message as message body is null, and option allowNullBody is false."); throw v; label: if v == null goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("Cannot determine specific JmsMessage type to use from body class. Will use generic JmsMessage. Body class: \u. If you want to send a POJO then your class might need to implement java.io.Serializable, or you can force a specific type by setting the jmsMessageType option on the JMS endpoint."); interfaceinvoke v.(v); label: v = interfaceinvoke v.(); interfaceinvoke v.(2); return v; } protected org.apache.camel.component.jms.JmsMessageType getJMSMessageTypeForBody(org.apache.camel.Exchange, java.lang.Object, java.util.Map, javax.jms.Session, org.apache.camel.CamelContext) { org.apache.camel.component.jms.JmsEndpoint v; org.apache.camel.Exchange v; javax.jms.Session v; org.apache.camel.component.jms.JmsMessageType v, v, v, v; java.util.Map v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.camel.CamelContext v, v, v; org.apache.camel.component.jms.JmsConfiguration v; org.apache.camel.TypeConverter v, v; java.lang.Object v, v, v; org.apache.camel.component.jms.JmsBinding v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: org.apache.camel.Exchange; v := @parameter: java.lang.Object; v := @parameter: java.util.Map; v := @parameter: javax.jms.Session; v := @parameter: org.apache.camel.CamelContext; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = null; v = v instanceof org.w3c.dom.Node; if v != 0 goto label; v = v instanceof java.lang.String; if v == 0 goto label; label: v = ; goto label; label: v = v instanceof byte[]; if v != 0 goto label; v = v instanceof java.nio.ByteBuffer; if v == 0 goto label; label: v = ; goto label; label: v = v instanceof org.apache.camel.WrappedFile; if v != 0 goto label; v = v instanceof java.io.File; if v != 0 goto label; v = v instanceof java.io.Reader; if v != 0 goto label; v = v instanceof java.io.InputStream; if v != 0 goto label; v = v instanceof org.apache.camel.StreamCache; if v == 0 goto label; label: if v == 0 goto label; v = ; goto label; label: v = ; label: v = v; goto label; label: v = v instanceof java.util.Map; if v == 0 goto label; v = ; goto label; label: v = v instanceof java.io.Serializable; if v == 0 goto label; v = ; goto label; label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(class "Ljava/io/File;", v); if v != null goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(class "Ljava/io/InputStream;", v); if v == null goto label; label: if v == 0 goto label; v = ; goto label; label: v = ; label: v = v; label: v = ; if v != v goto label; v = staticinvoke (v, "Artemis"); if v == 0 goto label; v = ; label: return v; } protected javax.jms.Message createJmsMessageForType(org.apache.camel.Exchange, java.lang.Object, java.util.Map, javax.jms.Session, org.apache.camel.CamelContext, org.apache.camel.component.jms.JmsMessageType) throws javax.jms.JMSException { byte[] v; org.apache.camel.NoTypeConversionAvailableException v, v; javax.jms.MapMessage v; java.lang.Integer v; javax.jms.Session v; int[] v; java.lang.Long v; java.util.Map v; boolean v; javax.jms.StreamMessage v; java.lang.Exception v; javax.jms.MessageFormatException v, v, v; org.apache.camel.component.jms.JmsBinding v; javax.jms.ObjectMessage v; long v; org.apache.camel.Exchange v; org.apache.camel.component.jms.JmsMessageType v; int v, v, v, v; java.lang.String v, v, v; org.apache.camel.CamelContext v; org.slf4j.Logger v, v, v, v, v; javax.jms.TextMessage v; javax.jms.BytesMessage v; org.apache.camel.TypeConverter v, v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: org.apache.camel.Exchange; v := @parameter: java.lang.Object; v := @parameter: java.util.Map; v := @parameter: javax.jms.Session; v := @parameter: org.apache.camel.CamelContext; v := @parameter: org.apache.camel.component.jms.JmsMessageType; v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; default: goto label; }; label: v = interfaceinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(class "Ljava/lang/String;", v, v); interfaceinvoke v.(v); label: return v; label: v = interfaceinvoke v.(); if v == null goto label; label: v = staticinvoke (v, "Artemis"); if v == 0 goto label; v = ; interfaceinvoke v.("Optimised for Artemis: Streaming payload in BytesMessage"); v = interfaceinvoke v.(); v = interfaceinvoke v.(class "Ljava/io/InputStream;", v, v); interfaceinvoke v.("JMS_AMQ_InputStream", v); v = ; interfaceinvoke v.("Optimised for Artemis: Finished streaming payload in BytesMessage"); goto label; label: v = interfaceinvoke v.(); v = interfaceinvoke v.(class "[B", v, v); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = new javax.jms.MessageFormatException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); throw v; label: return v; label: v = interfaceinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(class "Ljava/util/Map;", v, v); virtualinvoke v.(v, v, v); label: return v; label: v = interfaceinvoke v.(); if v == null goto label; label: v = interfaceinvoke v.(); v = interfaceinvoke v.(class "Ljava/io/Serializable;", v, v); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = new javax.jms.MessageFormatException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); throw v; label: return v; label: v = interfaceinvoke v.(); if v == null goto label; v = 0L; label: v = interfaceinvoke v.(); v = interfaceinvoke v.(class "Ljava/io/InputStream;", v, v); v = ; interfaceinvoke v.("Writing payload in StreamMessage"); v = newarray (byte)[131072]; v = 0; v = 0; label: if v < 0 goto label; v = v + 1; v = virtualinvoke v.(v); if v < 0 goto label; v = v + v; v = ; v = staticinvoke (v); interfaceinvoke v.("Writing payload chunk {} as bytes in StreamMessage", v); interfaceinvoke v.(v, 0, v); goto label; label: v = ; v = staticinvoke (v); interfaceinvoke v.("Finished writing payload (size {}) as bytes in StreamMessage", v); label: goto label; label: v := @caughtexception; v = new javax.jms.MessageFormatException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); throw v; label: return v; label: return null; catch org.apache.camel.NoTypeConversionAvailableException from label to label with label; catch org.apache.camel.NoTypeConversionAvailableException from label to label with label; catch org.apache.camel.NoTypeConversionAvailableException from label to label with label; catch java.io.IOException from label to label with label; } protected void populateMapMessage(javax.jms.MapMessage, java.util.Map, org.apache.camel.CamelContext) throws javax.jms.JMSException { org.apache.camel.CamelContext v; java.util.Iterator v; java.util.Set v; javax.jms.MapMessage v; java.util.Map v; java.lang.Object v, v, v, v; org.apache.camel.component.jms.JmsBinding v; boolean v; v := @this: org.apache.camel.component.jms.JmsBinding; v := @parameter: javax.jms.MapMessage; v := @parameter: java.util.Map; v := @parameter: org.apache.camel.CamelContext; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v, class "Ljava/lang/String;", v); if v == null goto label; v = interfaceinvoke v.