public class org.apache.camel.component.log.LogEndpoint extends org.apache.camel.impl.ProcessorEndpoint
{
private volatile org.apache.camel.Processor logger;
private org.slf4j.Logger providedLogger;
private org.apache.camel.spi.ExchangeFormatter localFormatter;
private java.lang.String loggerName;
private java.lang.String level;
private java.lang.String marker;
private java.lang.Integer groupSize;
private java.lang.Long groupInterval;
private java.lang.Boolean groupActiveOnly;
private java.lang.Long groupDelay;
private org.apache.camel.processor.DefaultExchangeFormatter exchangeFormatter;
private java.lang.Boolean logMask;
public void <init>()
{
org.apache.camel.component.log.LogEndpoint v;
v := @this: org.apache.camel.component.log.LogEndpoint;
specialinvoke v.<org.apache.camel.impl.ProcessorEndpoint: void <init>()>();
return;
}
public void <init>(java.lang.String, org.apache.camel.Component)
{
org.apache.camel.component.log.LogEndpoint v;
org.apache.camel.Component v;
java.lang.String v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v := @parameter: java.lang.String;
v := @parameter: org.apache.camel.Component;
specialinvoke v.<org.apache.camel.impl.ProcessorEndpoint: void <init>(java.lang.String,org.apache.camel.Component)>(v, v);
return;
}
public void <init>(java.lang.String, org.apache.camel.Component, org.apache.camel.Processor)
{
org.apache.camel.component.log.LogEndpoint v;
org.apache.camel.Processor v;
org.apache.camel.Component v;
java.lang.String v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v := @parameter: java.lang.String;
v := @parameter: org.apache.camel.Component;
v := @parameter: org.apache.camel.Processor;
specialinvoke v.<org.apache.camel.impl.ProcessorEndpoint: void <init>(java.lang.String,org.apache.camel.Component)>(v, v);
virtualinvoke v.<org.apache.camel.component.log.LogEndpoint: void setLogger(org.apache.camel.Processor)>(v);
return;
}
protected void doStart() throws java.lang.Exception
{
org.apache.camel.component.log.LogEndpoint v;
org.apache.camel.Processor v, v, v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v = v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.Processor logger>;
if v != null goto label;
v = virtualinvoke v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.Processor createLogger()>();
v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.Processor logger> = v;
label:
v = v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.Processor logger>;
staticinvoke <org.apache.camel.util.ServiceHelper: void startService(java.lang.Object)>(v);
return;
}
protected void doStop() throws java.lang.Exception
{
org.apache.camel.component.log.LogEndpoint v;
org.apache.camel.Processor v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v = v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.Processor logger>;
staticinvoke <org.apache.camel.util.ServiceHelper: void stopService(java.lang.Object)>(v);
return;
}
public void setLogger(org.apache.camel.Processor)
{
org.apache.camel.component.log.LogEndpoint v;
org.apache.camel.Processor v, v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v := @parameter: org.apache.camel.Processor;
v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.Processor logger> = v;
v = v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.Processor logger>;
virtualinvoke v.<org.apache.camel.component.log.LogEndpoint: void setProcessor(org.apache.camel.Processor)>(v);
return;
}
public org.apache.camel.Processor getLogger()
{
org.apache.camel.component.log.LogEndpoint v;
org.apache.camel.Processor v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v = v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.Processor logger>;
return v;
}
public org.apache.camel.Producer createProducer() throws java.lang.Exception
{
org.apache.camel.component.log.LogEndpoint v;
org.apache.camel.Processor v, v, v, v;
org.apache.camel.component.log.LogProducer v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v = v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.Processor logger>;
if v != null goto label;
v = virtualinvoke v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.Processor createLogger()>();
v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.Processor logger> = v;
label:
v = v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.Processor logger>;
staticinvoke <org.apache.camel.util.ServiceHelper: void startService(java.lang.Object)>(v);
v = new org.apache.camel.component.log.LogProducer;
v = v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.Processor logger>;
specialinvoke v.<org.apache.camel.component.log.LogProducer: void <init>(org.apache.camel.Endpoint,org.apache.camel.Processor)>(v, v);
return v;
}
protected java.lang.String createEndpointUri()
{
org.apache.camel.component.log.LogEndpoint v;
org.apache.camel.Processor v;
java.lang.String v, v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v = v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.Processor logger>;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
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[])>("log:\u0001");
return v;
}
protected org.apache.camel.Processor createLogger() throws java.lang.Exception
{
java.lang.Integer v, v;
org.apache.camel.processor.CamelLogProcessor v;
java.lang.Long v, v, v;
org.apache.camel.util.CamelLogger v, v, v;
java.lang.Boolean v, v;
java.lang.String v, v, v, v, v;
org.apache.camel.spi.MaskingFormatter v;
org.apache.camel.LoggingLevel v;
org.apache.camel.CamelContext v, v;
org.apache.camel.spi.ExchangeFormatter v;
org.slf4j.Logger v, v;
java.util.Set v;
org.apache.camel.component.log.LogEndpoint v;
org.apache.camel.processor.ThroughputLogger v, v;
org.apache.camel.AsyncProcessor v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v = <org.apache.camel.LoggingLevel: org.apache.camel.LoggingLevel INFO>;
v = v.<org.apache.camel.component.log.LogEndpoint: java.lang.String level>;
if v == null goto label;
v = v.<org.apache.camel.component.log.LogEndpoint: java.lang.String level>;
v = staticinvoke <org.apache.camel.LoggingLevel: org.apache.camel.LoggingLevel valueOf(java.lang.String)>(v);
label:
v = v.<org.apache.camel.component.log.LogEndpoint: org.slf4j.Logger providedLogger>;
if v != null goto label;
v = new org.apache.camel.util.CamelLogger;
v = v.<org.apache.camel.component.log.LogEndpoint: java.lang.String loggerName>;
v = virtualinvoke v.<org.apache.camel.component.log.LogEndpoint: java.lang.String getMarker()>();
specialinvoke v.<org.apache.camel.util.CamelLogger: void <init>(java.lang.String,org.apache.camel.LoggingLevel,java.lang.String)>(v, v, v);
v = v;
goto label;
label:
v = new org.apache.camel.util.CamelLogger;
v = v.<org.apache.camel.component.log.LogEndpoint: org.slf4j.Logger providedLogger>;
v = virtualinvoke v.<org.apache.camel.component.log.LogEndpoint: java.lang.String getMarker()>();
specialinvoke v.<org.apache.camel.util.CamelLogger: void <init>(org.slf4j.Logger,org.apache.camel.LoggingLevel,java.lang.String)>(v, v, v);
v = v;
label:
v = virtualinvoke v.<org.apache.camel.component.log.LogEndpoint: java.lang.Integer getGroupSize()>();
if v == null goto label;
v = new org.apache.camel.processor.ThroughputLogger;
v = virtualinvoke v.<org.apache.camel.component.log.LogEndpoint: java.lang.Integer getGroupSize()>();
specialinvoke v.<org.apache.camel.processor.ThroughputLogger: void <init>(org.apache.camel.util.CamelLogger,java.lang.Integer)>(v, v);
v = v;
goto label;
label:
v = virtualinvoke v.<org.apache.camel.component.log.LogEndpoint: java.lang.Long getGroupInterval()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.component.log.LogEndpoint: java.lang.Boolean getGroupActiveOnly()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.component.log.LogEndpoint: java.lang.Boolean getGroupActiveOnly()>();
goto label;
label:
v = <java.lang.Boolean: java.lang.Boolean TRUE>;
label:
v = virtualinvoke v.<org.apache.camel.component.log.LogEndpoint: java.lang.Long getGroupDelay()>();
v = new org.apache.camel.processor.ThroughputLogger;
v = virtualinvoke v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.CamelContext getCamelContext()>();
v = virtualinvoke v.<org.apache.camel.component.log.LogEndpoint: java.lang.Long getGroupInterval()>();
specialinvoke v.<org.apache.camel.processor.ThroughputLogger: void <init>(org.apache.camel.util.CamelLogger,org.apache.camel.CamelContext,java.lang.Long,java.lang.Long,java.lang.Boolean)>(v, v, v, v, v);
v = v;
goto label;
label:
v = new org.apache.camel.processor.CamelLogProcessor;
v = v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.spi.ExchangeFormatter localFormatter>;
v = specialinvoke v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.spi.MaskingFormatter getMaskingFormatter()>();
v = virtualinvoke v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.CamelContext getCamelContext()>();
v = interfaceinvoke v.<org.apache.camel.CamelContext: java.util.Set getLogListeners()>();
specialinvoke v.<org.apache.camel.processor.CamelLogProcessor: void <init>(org.apache.camel.util.CamelLogger,org.apache.camel.spi.ExchangeFormatter,org.apache.camel.spi.MaskingFormatter,java.util.Set)>(v, v, v, v);
v = v;
label:
virtualinvoke v.<org.apache.camel.component.log.LogEndpoint: void setProcessor(org.apache.camel.Processor)>(v);
return v;
}
private org.apache.camel.spi.MaskingFormatter getMaskingFormatter()
{
org.apache.camel.CamelContext v, v;
org.apache.camel.spi.Registry v;
org.apache.camel.processor.DefaultMaskingFormatter v;
org.apache.camel.component.log.LogEndpoint v;
java.lang.Boolean v, v;
java.lang.Object v;
boolean v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v = v.<org.apache.camel.component.log.LogEndpoint: java.lang.Boolean logMask>;
if v == null goto label;
v = v.<org.apache.camel.component.log.LogEndpoint: java.lang.Boolean logMask>;
goto label;
label:
v = virtualinvoke v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.CamelContext getCamelContext()>();
v = interfaceinvoke v.<org.apache.camel.CamelContext: java.lang.Boolean isLogMask()>();
label:
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.CamelContext getCamelContext()>();
v = interfaceinvoke v.<org.apache.camel.CamelContext: org.apache.camel.spi.Registry getRegistry()>();
v = interfaceinvoke v.<org.apache.camel.spi.Registry: java.lang.Object lookupByNameAndType(java.lang.String,java.lang.Class)>("CamelCustomLogMask", class "Lorg/apache/camel/spi/MaskingFormatter;");
if v != null goto label;
v = new org.apache.camel.processor.DefaultMaskingFormatter;
specialinvoke v.<org.apache.camel.processor.DefaultMaskingFormatter: void <init>()>();
v = v;
label:
return v;
label:
return null;
}
public java.lang.String getLevel()
{
org.apache.camel.component.log.LogEndpoint v;
java.lang.String v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v = v.<org.apache.camel.component.log.LogEndpoint: java.lang.String level>;
return v;
}
public void setLevel(java.lang.String)
{
org.apache.camel.component.log.LogEndpoint v;
java.lang.String v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v := @parameter: java.lang.String;
v.<org.apache.camel.component.log.LogEndpoint: java.lang.String level> = v;
return;
}
public java.lang.String getMarker()
{
org.apache.camel.component.log.LogEndpoint v;
java.lang.String v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v = v.<org.apache.camel.component.log.LogEndpoint: java.lang.String marker>;
return v;
}
public void setMarker(java.lang.String)
{
org.apache.camel.component.log.LogEndpoint v;
java.lang.String v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v := @parameter: java.lang.String;
v.<org.apache.camel.component.log.LogEndpoint: java.lang.String marker> = v;
return;
}
public java.lang.Integer getGroupSize()
{
org.apache.camel.component.log.LogEndpoint v;
java.lang.Integer v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v = v.<org.apache.camel.component.log.LogEndpoint: java.lang.Integer groupSize>;
return v;
}
public void setGroupSize(java.lang.Integer)
{
org.apache.camel.component.log.LogEndpoint v;
java.lang.Integer v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v := @parameter: java.lang.Integer;
v.<org.apache.camel.component.log.LogEndpoint: java.lang.Integer groupSize> = v;
return;
}
public java.lang.Long getGroupInterval()
{
org.apache.camel.component.log.LogEndpoint v;
java.lang.Long v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v = v.<org.apache.camel.component.log.LogEndpoint: java.lang.Long groupInterval>;
return v;
}
public void setGroupInterval(java.lang.Long)
{
org.apache.camel.component.log.LogEndpoint v;
java.lang.Long v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v := @parameter: java.lang.Long;
v.<org.apache.camel.component.log.LogEndpoint: java.lang.Long groupInterval> = v;
return;
}
public java.lang.Boolean getGroupActiveOnly()
{
org.apache.camel.component.log.LogEndpoint v;
java.lang.Boolean v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v = v.<org.apache.camel.component.log.LogEndpoint: java.lang.Boolean groupActiveOnly>;
return v;
}
public void setGroupActiveOnly(java.lang.Boolean)
{
org.apache.camel.component.log.LogEndpoint v;
java.lang.Boolean v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.component.log.LogEndpoint: java.lang.Boolean groupActiveOnly> = v;
return;
}
public java.lang.Long getGroupDelay()
{
org.apache.camel.component.log.LogEndpoint v;
java.lang.Long v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v = v.<org.apache.camel.component.log.LogEndpoint: java.lang.Long groupDelay>;
return v;
}
public void setGroupDelay(java.lang.Long)
{
org.apache.camel.component.log.LogEndpoint v;
java.lang.Long v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v := @parameter: java.lang.Long;
v.<org.apache.camel.component.log.LogEndpoint: java.lang.Long groupDelay> = v;
return;
}
public org.apache.camel.spi.ExchangeFormatter getLocalFormatter()
{
org.apache.camel.component.log.LogEndpoint v;
org.apache.camel.spi.ExchangeFormatter v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v = v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.spi.ExchangeFormatter localFormatter>;
return v;
}
public void setLocalFormatter(org.apache.camel.spi.ExchangeFormatter)
{
org.apache.camel.component.log.LogEndpoint v;
org.apache.camel.spi.ExchangeFormatter v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v := @parameter: org.apache.camel.spi.ExchangeFormatter;
v.<org.apache.camel.component.log.LogEndpoint: org.apache.camel.spi.ExchangeFormatter localFormatter> = v;
return;
}
public org.slf4j.Logger getProvidedLogger()
{
org.apache.camel.component.log.LogEndpoint v;
org.slf4j.Logger v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v = v.<org.apache.camel.component.log.LogEndpoint: org.slf4j.Logger providedLogger>;
return v;
}
public void setProvidedLogger(org.slf4j.Logger)
{
org.apache.camel.component.log.LogEndpoint v;
org.slf4j.Logger v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v := @parameter: org.slf4j.Logger;
v.<org.apache.camel.component.log.LogEndpoint: org.slf4j.Logger providedLogger> = v;
return;
}
public java.lang.String getLoggerName()
{
org.apache.camel.component.log.LogEndpoint v;
java.lang.String v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v = v.<org.apache.camel.component.log.LogEndpoint: java.lang.String loggerName>;
return v;
}
public void setLoggerName(java.lang.String)
{
org.apache.camel.component.log.LogEndpoint v;
java.lang.String v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v := @parameter: java.lang.String;
v.<org.apache.camel.component.log.LogEndpoint: java.lang.String loggerName> = v;
return;
}
public java.lang.Boolean getLogMask()
{
org.apache.camel.component.log.LogEndpoint v;
java.lang.Boolean v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v = v.<org.apache.camel.component.log.LogEndpoint: java.lang.Boolean logMask>;
return v;
}
public void setLogMask(java.lang.Boolean)
{
org.apache.camel.component.log.LogEndpoint v;
java.lang.Boolean v;
v := @this: org.apache.camel.component.log.LogEndpoint;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.component.log.LogEndpoint: java.lang.Boolean logMask> = v;
return;
}
}