public class org.apache.camel.impl.MDCUnitOfWork extends org.apache.camel.impl.DefaultUnitOfWork
{
public static final java.lang.String MDC_BREADCRUMB_ID;
public static final java.lang.String MDC_EXCHANGE_ID;
public static final java.lang.String MDC_MESSAGE_ID;
public static final java.lang.String MDC_CORRELATION_ID;
public static final java.lang.String MDC_ROUTE_ID;
public static final java.lang.String MDC_CAMEL_CONTEXT_ID;
public static final java.lang.String MDC_TRANSACTION_KEY;
private static final org.slf4j.Logger LOG;
private final java.lang.String originalBreadcrumbId;
private final java.lang.String originalExchangeId;
private final java.lang.String originalMessageId;
private final java.lang.String originalCorrelationId;
private final java.lang.String originalRouteId;
private final java.lang.String originalCamelContextId;
private final java.lang.String originalTransactionKey;
public void <init>(org.apache.camel.Exchange)
{
org.apache.camel.Message v, v, v;
org.apache.camel.Exchange v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
boolean v;
org.apache.camel.impl.MDCUnitOfWork v;
org.apache.camel.CamelContext v;
org.slf4j.Logger v;
java.lang.Object v, v;
v := @this: org.apache.camel.impl.MDCUnitOfWork;
v := @parameter: org.apache.camel.Exchange;
v = <org.apache.camel.impl.MDCUnitOfWork: org.slf4j.Logger LOG>;
specialinvoke v.<org.apache.camel.impl.DefaultUnitOfWork: void <init>(org.apache.camel.Exchange,org.slf4j.Logger)>(v, v);
v = staticinvoke <org.slf4j.MDC: java.lang.String get(java.lang.String)>("camel.exchangeId");
v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalExchangeId> = v;
v = staticinvoke <org.slf4j.MDC: java.lang.String get(java.lang.String)>("camel.messageId");
v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalMessageId> = v;
v = staticinvoke <org.slf4j.MDC: java.lang.String get(java.lang.String)>("camel.breadcrumbId");
v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalBreadcrumbId> = v;
v = staticinvoke <org.slf4j.MDC: java.lang.String get(java.lang.String)>("camel.correlationId");
v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalCorrelationId> = v;
v = staticinvoke <org.slf4j.MDC: java.lang.String get(java.lang.String)>("camel.routeId");
v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalRouteId> = v;
v = staticinvoke <org.slf4j.MDC: java.lang.String get(java.lang.String)>("camel.contextId");
v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalCamelContextId> = v;
v = staticinvoke <org.slf4j.MDC: java.lang.String get(java.lang.String)>("camel.transactionKey");
v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalTransactionKey> = v;
v = interfaceinvoke v.<org.apache.camel.Exchange: java.lang.String getExchangeId()>();
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("camel.exchangeId", v);
v = interfaceinvoke v.<org.apache.camel.Exchange: boolean hasOut()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.Message getOut()>();
v = interfaceinvoke v.<org.apache.camel.Message: java.lang.String getMessageId()>();
goto label;
label:
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.Message getIn()>();
v = interfaceinvoke v.<org.apache.camel.Message: java.lang.String getMessageId()>();
label:
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("camel.messageId", v);
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.CamelContext getContext()>();
v = interfaceinvoke v.<org.apache.camel.CamelContext: java.lang.String getName()>();
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("camel.contextId", v);
v = interfaceinvoke v.<org.apache.camel.Exchange: java.lang.Object getProperty(java.lang.String,java.lang.Class)>("CamelCorrelationId", class "Ljava/lang/String;");
if v == null goto label;
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("camel.correlationId", v);
label:
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.Message getIn()>();
v = interfaceinvoke v.<org.apache.camel.Message: java.lang.Object getHeader(java.lang.String,java.lang.Class)>("breadcrumbId", class "Ljava/lang/String;");
if v == null goto label;
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("camel.breadcrumbId", v);
label:
return;
}
public org.apache.camel.spi.UnitOfWork newInstance(org.apache.camel.Exchange)
{
org.apache.camel.Exchange v;
org.apache.camel.impl.MDCUnitOfWork v, v;
v := @this: org.apache.camel.impl.MDCUnitOfWork;
v := @parameter: org.apache.camel.Exchange;
v = new org.apache.camel.impl.MDCUnitOfWork;
specialinvoke v.<org.apache.camel.impl.MDCUnitOfWork: void <init>(org.apache.camel.Exchange)>(v);
return v;
}
public void stop() throws java.lang.Exception
{
org.apache.camel.impl.MDCUnitOfWork v;
v := @this: org.apache.camel.impl.MDCUnitOfWork;
specialinvoke v.<org.apache.camel.impl.DefaultUnitOfWork: void stop()>();
virtualinvoke v.<org.apache.camel.impl.MDCUnitOfWork: void clear()>();
return;
}
public void pushRouteContext(org.apache.camel.spi.RouteContext)
{
org.apache.camel.model.RouteDefinition v;
java.lang.String v;
org.apache.camel.spi.RouteContext v;
org.apache.camel.impl.MDCUnitOfWork v;
v := @this: org.apache.camel.impl.MDCUnitOfWork;
v := @parameter: org.apache.camel.spi.RouteContext;
specialinvoke v.<org.apache.camel.impl.DefaultUnitOfWork: void pushRouteContext(org.apache.camel.spi.RouteContext)>(v);
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: org.apache.camel.model.RouteDefinition getRoute()>();
v = virtualinvoke v.<org.apache.camel.model.RouteDefinition: java.lang.String getId()>();
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("camel.routeId", v);
return;
}
public org.apache.camel.spi.RouteContext popRouteContext()
{
org.apache.camel.model.RouteDefinition v;
java.lang.String v;
org.apache.camel.spi.RouteContext v, v;
org.apache.camel.impl.MDCUnitOfWork v;
v := @this: org.apache.camel.impl.MDCUnitOfWork;
v = specialinvoke v.<org.apache.camel.impl.DefaultUnitOfWork: org.apache.camel.spi.RouteContext popRouteContext()>();
v = virtualinvoke v.<org.apache.camel.impl.MDCUnitOfWork: org.apache.camel.spi.RouteContext getRouteContext()>();
if v == null goto label;
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: org.apache.camel.model.RouteDefinition getRoute()>();
v = virtualinvoke v.<org.apache.camel.model.RouteDefinition: java.lang.String getId()>();
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("camel.routeId", v);
goto label;
label:
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("camel.routeId");
label:
return v;
}
public void beginTransactedBy(java.lang.Object)
{
java.lang.Object v;
java.lang.String v;
org.apache.camel.impl.MDCUnitOfWork v;
v := @this: org.apache.camel.impl.MDCUnitOfWork;
v := @parameter: java.lang.Object;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("camel.transactionKey", v);
specialinvoke v.<org.apache.camel.impl.DefaultUnitOfWork: void beginTransactedBy(java.lang.Object)>(v);
return;
}
public void endTransactedBy(java.lang.Object)
{
java.lang.Object v;
org.apache.camel.impl.MDCUnitOfWork v;
v := @this: org.apache.camel.impl.MDCUnitOfWork;
v := @parameter: java.lang.Object;
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("camel.transactionKey");
specialinvoke v.<org.apache.camel.impl.DefaultUnitOfWork: void endTransactedBy(java.lang.Object)>(v);
return;
}
public org.apache.camel.AsyncCallback beforeProcess(org.apache.camel.Processor, org.apache.camel.Exchange, org.apache.camel.AsyncCallback)
{
org.apache.camel.Processor v;
org.apache.camel.impl.MDCUnitOfWork$MDCCallback v;
org.apache.camel.AsyncCallback v;
org.apache.camel.Exchange v;
org.apache.camel.impl.MDCUnitOfWork v;
v := @this: org.apache.camel.impl.MDCUnitOfWork;
v := @parameter: org.apache.camel.Processor;
v := @parameter: org.apache.camel.Exchange;
v := @parameter: org.apache.camel.AsyncCallback;
v = new org.apache.camel.impl.MDCUnitOfWork$MDCCallback;
specialinvoke v.<org.apache.camel.impl.MDCUnitOfWork$MDCCallback: void <init>(org.apache.camel.AsyncCallback)>(v);
return v;
}
public void afterProcess(org.apache.camel.Processor, org.apache.camel.Exchange, org.apache.camel.AsyncCallback, boolean)
{
org.apache.camel.Processor v;
org.apache.camel.AsyncCallback v;
org.apache.camel.Exchange v;
boolean v;
org.apache.camel.impl.MDCUnitOfWork v;
v := @this: org.apache.camel.impl.MDCUnitOfWork;
v := @parameter: org.apache.camel.Processor;
v := @parameter: org.apache.camel.Exchange;
v := @parameter: org.apache.camel.AsyncCallback;
v := @parameter: boolean;
if v != 0 goto label;
virtualinvoke v.<org.apache.camel.impl.MDCUnitOfWork: void clear()>();
label:
specialinvoke v.<org.apache.camel.impl.DefaultUnitOfWork: void afterProcess(org.apache.camel.Processor,org.apache.camel.Exchange,org.apache.camel.AsyncCallback,boolean)>(v, v, v, v);
return;
}
public void clear()
{
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.camel.impl.MDCUnitOfWork v;
v := @this: org.apache.camel.impl.MDCUnitOfWork;
v = v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalBreadcrumbId>;
if v == null goto label;
v = v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalBreadcrumbId>;
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("camel.breadcrumbId", v);
goto label;
label:
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("camel.breadcrumbId");
label:
v = v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalExchangeId>;
if v == null goto label;
v = v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalExchangeId>;
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("camel.exchangeId", v);
goto label;
label:
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("camel.exchangeId");
label:
v = v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalMessageId>;
if v == null goto label;
v = v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalMessageId>;
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("camel.messageId", v);
goto label;
label:
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("camel.messageId");
label:
v = v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalCorrelationId>;
if v == null goto label;
v = v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalCorrelationId>;
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("camel.correlationId", v);
goto label;
label:
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("camel.correlationId");
label:
v = v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalRouteId>;
if v == null goto label;
v = v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalRouteId>;
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("camel.routeId", v);
goto label;
label:
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("camel.routeId");
label:
v = v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalCamelContextId>;
if v == null goto label;
v = v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalCamelContextId>;
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("camel.contextId", v);
goto label;
label:
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("camel.contextId");
label:
v = v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalTransactionKey>;
if v == null goto label;
v = v.<org.apache.camel.impl.MDCUnitOfWork: java.lang.String originalTransactionKey>;
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("camel.transactionKey", v);
goto label;
label:
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("camel.transactionKey");
label:
return;
}
public java.lang.String toString()
{
org.apache.camel.impl.MDCUnitOfWork v;
v := @this: org.apache.camel.impl.MDCUnitOfWork;
return "MDCUnitOfWork";
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/camel/impl/MDCUnitOfWork;");
<org.apache.camel.impl.MDCUnitOfWork: org.slf4j.Logger LOG> = v;
return;
}
}