public class org.apache.activemq.camel.component.OriginalDestinationPropagateStrategy extends java.lang.Object implements org.apache.camel.component.jms.MessageCreatedStrategy
{
private static final transient org.slf4j.Logger LOG;
public void <init>()
{
org.apache.activemq.camel.component.OriginalDestinationPropagateStrategy v;
v := @this: org.apache.activemq.camel.component.OriginalDestinationPropagateStrategy;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void onMessageCreated(javax.jms.Message, javax.jms.Session, org.apache.camel.Exchange, java.lang.Throwable)
{
java.lang.Throwable v;
org.slf4j.Logger v;
org.apache.camel.Message v;
org.apache.camel.Exchange v;
org.apache.activemq.command.ActiveMQDestination v, v;
javax.jms.Session v;
org.apache.activemq.camel.component.OriginalDestinationPropagateStrategy v;
java.lang.Object v;
javax.jms.Message v, v;
boolean v, v, v;
v := @this: org.apache.activemq.camel.component.OriginalDestinationPropagateStrategy;
v := @parameter: javax.jms.Message;
v := @parameter: javax.jms.Session;
v := @parameter: org.apache.camel.Exchange;
v := @parameter: java.lang.Throwable;
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.Message getIn()>();
v = v instanceof org.apache.camel.component.jms.JmsMessage;
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.camel.Exchange: java.lang.Object getIn(java.lang.Class)>(class "Lorg/apache/camel/component/jms/JmsMessage;");
v = virtualinvoke v.<org.apache.camel.component.jms.JmsMessage: javax.jms.Message getJmsMessage()>();
if v == null goto label;
v = v instanceof org.apache.activemq.command.ActiveMQMessage;
if v == 0 goto label;
v = v instanceof org.apache.activemq.command.ActiveMQMessage;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.command.ActiveMQDestination getOriginalDestination()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: org.apache.activemq.command.ActiveMQDestination getDestination()>();
if v == null goto label;
v = <org.apache.activemq.camel.component.OriginalDestinationPropagateStrategy: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object,java.lang.Object)>("Setting OriginalDestination: {} on {}", v, v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQMessage: void setOriginalDestination(org.apache.activemq.command.ActiveMQDestination)>(v);
label:
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/camel/component/OriginalDestinationPropagateStrategy;");
<org.apache.activemq.camel.component.OriginalDestinationPropagateStrategy: org.slf4j.Logger LOG> = v;
return;
}
}