public class org.apache.camel.processor.ThroughputLogger extends org.apache.camel.support.ServiceSupport implements org.apache.camel.AsyncProcessor, org.apache.camel.spi.IdAware
{
private static final org.slf4j.Logger LOG;
private java.lang.String id;
private final java.util.concurrent.atomic.AtomicInteger receivedCounter;
private java.text.NumberFormat numberFormat;
private long groupReceivedCount;
private boolean groupActiveOnly;
private java.lang.Integer groupSize;
private long groupDelay;
private java.lang.Long groupInterval;
private long startTime;
private long groupStartTime;
private java.lang.String action;
private org.apache.camel.CamelContext camelContext;
private java.util.concurrent.ScheduledExecutorService logSchedulerService;
private org.apache.camel.util.CamelLogger log;
private java.lang.String lastLogMessage;
private double rate;
private double average;
public void <init>(org.apache.camel.util.CamelLogger)
{
java.util.concurrent.atomic.AtomicInteger v;
org.apache.camel.util.CamelLogger v;
org.apache.camel.processor.ThroughputLogger v;
java.text.NumberFormat v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v := @parameter: org.apache.camel.util.CamelLogger;
specialinvoke v.<org.apache.camel.support.ServiceSupport: void <init>()>();
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>()>();
v.<org.apache.camel.processor.ThroughputLogger: java.util.concurrent.atomic.AtomicInteger receivedCounter> = v;
v = staticinvoke <java.text.NumberFormat: java.text.NumberFormat getNumberInstance()>();
v.<org.apache.camel.processor.ThroughputLogger: java.text.NumberFormat numberFormat> = v;
v.<org.apache.camel.processor.ThroughputLogger: long groupDelay> = 1000L;
v.<org.apache.camel.processor.ThroughputLogger: java.lang.String action> = "Received";
v.<org.apache.camel.processor.ThroughputLogger: org.apache.camel.util.CamelLogger log> = v;
return;
}
public void <init>(org.apache.camel.util.CamelLogger, java.lang.Integer)
{
java.lang.Integer v;
org.apache.camel.util.CamelLogger v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v := @parameter: org.apache.camel.util.CamelLogger;
v := @parameter: java.lang.Integer;
specialinvoke v.<org.apache.camel.processor.ThroughputLogger: void <init>(org.apache.camel.util.CamelLogger)>(v);
virtualinvoke v.<org.apache.camel.processor.ThroughputLogger: void setGroupSize(java.lang.Integer)>(v);
return;
}
public void <init>(org.apache.camel.util.CamelLogger, org.apache.camel.CamelContext, java.lang.Long, java.lang.Long, java.lang.Boolean)
{
org.apache.camel.CamelContext v;
long v;
java.lang.Long v, v;
org.apache.camel.util.CamelLogger v;
org.apache.camel.processor.ThroughputLogger v;
java.lang.Boolean v;
boolean v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v := @parameter: org.apache.camel.util.CamelLogger;
v := @parameter: org.apache.camel.CamelContext;
v := @parameter: java.lang.Long;
v := @parameter: java.lang.Long;
v := @parameter: java.lang.Boolean;
specialinvoke v.<org.apache.camel.processor.ThroughputLogger: void <init>(org.apache.camel.util.CamelLogger)>(v);
v.<org.apache.camel.processor.ThroughputLogger: org.apache.camel.CamelContext camelContext> = v;
virtualinvoke v.<org.apache.camel.processor.ThroughputLogger: void setGroupInterval(java.lang.Long)>(v);
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
specialinvoke v.<org.apache.camel.processor.ThroughputLogger: void setGroupActiveOnly(boolean)>(v);
if v == null goto label;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
virtualinvoke v.<org.apache.camel.processor.ThroughputLogger: void setGroupDelay(long)>(v);
label:
return;
}
public java.lang.String getId()
{
java.lang.String v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v = v.<org.apache.camel.processor.ThroughputLogger: java.lang.String id>;
return v;
}
public void setId(java.lang.String)
{
java.lang.String v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v := @parameter: java.lang.String;
v.<org.apache.camel.processor.ThroughputLogger: java.lang.String id> = v;
return;
}
public void process(org.apache.camel.Exchange) throws java.lang.Exception
{
org.apache.camel.Exchange v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v := @parameter: org.apache.camel.Exchange;
staticinvoke <org.apache.camel.util.AsyncProcessorHelper: void process(org.apache.camel.AsyncProcessor,org.apache.camel.Exchange)>(v, v);
return;
}
public boolean process(org.apache.camel.Exchange, org.apache.camel.AsyncCallback)
{
org.apache.camel.AsyncCallback v;
long v, v;
org.apache.camel.Exchange v;
java.lang.Integer v, v;
byte v;
java.util.concurrent.atomic.AtomicInteger v;
org.apache.camel.util.CamelLogger v;
org.apache.camel.processor.ThroughputLogger v;
int v, v, v;
java.lang.String v, v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v := @parameter: org.apache.camel.Exchange;
v := @parameter: org.apache.camel.AsyncCallback;
v = v.<org.apache.camel.processor.ThroughputLogger: long startTime>;
v = v cmp 0L;
if v != 0 goto label;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v.<org.apache.camel.processor.ThroughputLogger: long startTime> = v;
label:
v = v.<org.apache.camel.processor.ThroughputLogger: java.util.concurrent.atomic.AtomicInteger receivedCounter>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int incrementAndGet()>();
v = v.<org.apache.camel.processor.ThroughputLogger: java.lang.Integer groupSize>;
if v == null goto label;
v = v.<org.apache.camel.processor.ThroughputLogger: java.lang.Integer groupSize>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v % v;
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.processor.ThroughputLogger: java.lang.String createLogMessage(org.apache.camel.Exchange,int)>(v, v);
v.<org.apache.camel.processor.ThroughputLogger: java.lang.String lastLogMessage> = v;
v = v.<org.apache.camel.processor.ThroughputLogger: org.apache.camel.util.CamelLogger log>;
v = v.<org.apache.camel.processor.ThroughputLogger: java.lang.String lastLogMessage>;
virtualinvoke v.<org.apache.camel.util.CamelLogger: void log(java.lang.String)>(v);
label:
interfaceinvoke v.<org.apache.camel.AsyncCallback: void done(boolean)>(1);
return 1;
}
public java.lang.Integer getGroupSize()
{
java.lang.Integer v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v = v.<org.apache.camel.processor.ThroughputLogger: java.lang.Integer groupSize>;
return v;
}
public void setGroupSize(java.lang.Integer)
{
org.apache.camel.processor.ThroughputLogger v;
int v;
java.lang.String v;
java.lang.IllegalArgumentException v;
java.lang.Integer v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v := @parameter: java.lang.Integer;
if v == null goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v > 0 goto label;
label:
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Integer)>(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[])>("groupSize must be positive, was: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<org.apache.camel.processor.ThroughputLogger: java.lang.Integer groupSize> = v;
return;
}
public java.lang.Long getGroupInterval()
{
java.lang.Long v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v = v.<org.apache.camel.processor.ThroughputLogger: java.lang.Long groupInterval>;
return v;
}
public void setGroupInterval(java.lang.Long)
{
byte v;
java.lang.Long v;
org.apache.camel.processor.ThroughputLogger v;
long v;
java.lang.String v;
java.lang.IllegalArgumentException v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v := @parameter: java.lang.Long;
if v == null goto label;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v cmp 0L;
if v > 0 goto label;
label:
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Long)>(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[])>("groupInterval must be positive, was: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<org.apache.camel.processor.ThroughputLogger: java.lang.Long groupInterval> = v;
return;
}
public long getGroupDelay()
{
long v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v = v.<org.apache.camel.processor.ThroughputLogger: long groupDelay>;
return v;
}
public void setGroupDelay(long)
{
long v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v := @parameter: long;
v.<org.apache.camel.processor.ThroughputLogger: long groupDelay> = v;
return;
}
public boolean getGroupActiveOnly()
{
boolean v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v = v.<org.apache.camel.processor.ThroughputLogger: boolean groupActiveOnly>;
return v;
}
private void setGroupActiveOnly(boolean)
{
boolean v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v := @parameter: boolean;
v.<org.apache.camel.processor.ThroughputLogger: boolean groupActiveOnly> = v;
return;
}
public java.text.NumberFormat getNumberFormat()
{
java.text.NumberFormat v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v = v.<org.apache.camel.processor.ThroughputLogger: java.text.NumberFormat numberFormat>;
return v;
}
public void setNumberFormat(java.text.NumberFormat)
{
java.text.NumberFormat v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v := @parameter: java.text.NumberFormat;
v.<org.apache.camel.processor.ThroughputLogger: java.text.NumberFormat numberFormat> = v;
return;
}
public java.lang.String getAction()
{
java.lang.String v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v = v.<org.apache.camel.processor.ThroughputLogger: java.lang.String action>;
return v;
}
public void setAction(java.lang.String)
{
java.lang.String v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v := @parameter: java.lang.String;
v.<org.apache.camel.processor.ThroughputLogger: java.lang.String action> = v;
return;
}
public void reset()
{
java.util.concurrent.atomic.AtomicInteger v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v.<org.apache.camel.processor.ThroughputLogger: long startTime> = 0L;
v = v.<org.apache.camel.processor.ThroughputLogger: java.util.concurrent.atomic.AtomicInteger receivedCounter>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: void set(int)>(0);
v.<org.apache.camel.processor.ThroughputLogger: long groupStartTime> = 0L;
v.<org.apache.camel.processor.ThroughputLogger: long groupReceivedCount> = 0L;
v.<org.apache.camel.processor.ThroughputLogger: double average> = 0.0;
v.<org.apache.camel.processor.ThroughputLogger: double rate> = 0.0;
v.<org.apache.camel.processor.ThroughputLogger: java.lang.String lastLogMessage> = null;
return;
}
public double getRate()
{
double v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v = v.<org.apache.camel.processor.ThroughputLogger: double rate>;
return v;
}
public double getAverage()
{
double v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v = v.<org.apache.camel.processor.ThroughputLogger: double average>;
return v;
}
public int getReceivedCounter()
{
int v;
java.util.concurrent.atomic.AtomicInteger v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v = v.<org.apache.camel.processor.ThroughputLogger: java.util.concurrent.atomic.AtomicInteger receivedCounter>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
return v;
}
public java.lang.String getLastLogMessage()
{
java.lang.String v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v = v.<org.apache.camel.processor.ThroughputLogger: java.lang.String lastLogMessage>;
return v;
}
public void doStart() throws java.lang.Exception
{
org.apache.camel.CamelContext v, v;
org.slf4j.Logger v;
long v, v;
java.util.concurrent.TimeUnit v;
java.lang.Long v, v, v;
org.apache.camel.processor.ThroughputLogger$ScheduledLogTask v;
org.apache.camel.processor.ThroughputLogger v;
java.util.concurrent.ScheduledExecutorService v, v;
org.apache.camel.spi.ExecutorServiceManager v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v = v.<org.apache.camel.processor.ThroughputLogger: java.lang.Long groupInterval>;
if v == null goto label;
v = v.<org.apache.camel.processor.ThroughputLogger: org.apache.camel.CamelContext camelContext>;
staticinvoke <org.apache.camel.util.ObjectHelper: java.lang.Object notNull(java.lang.Object,java.lang.String,java.lang.Object)>(v, "CamelContext", v);
v = v.<org.apache.camel.processor.ThroughputLogger: org.apache.camel.CamelContext camelContext>;
v = interfaceinvoke v.<org.apache.camel.CamelContext: org.apache.camel.spi.ExecutorServiceManager getExecutorServiceManager()>();
v = interfaceinvoke v.<org.apache.camel.spi.ExecutorServiceManager: java.util.concurrent.ScheduledExecutorService newSingleThreadScheduledExecutor(java.lang.Object,java.lang.String)>(v, "ThroughputLogger");
v.<org.apache.camel.processor.ThroughputLogger: java.util.concurrent.ScheduledExecutorService logSchedulerService> = v;
v = new org.apache.camel.processor.ThroughputLogger$ScheduledLogTask;
specialinvoke v.<org.apache.camel.processor.ThroughputLogger$ScheduledLogTask: void <init>(org.apache.camel.processor.ThroughputLogger)>(v);
v = <org.apache.camel.processor.ThroughputLogger: org.slf4j.Logger LOG>;
v = v.<org.apache.camel.processor.ThroughputLogger: java.lang.Long groupInterval>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Scheduling throughput log to run every {} millis.", v);
v = v.<org.apache.camel.processor.ThroughputLogger: java.util.concurrent.ScheduledExecutorService logSchedulerService>;
v = v.<org.apache.camel.processor.ThroughputLogger: long groupDelay>;
v = v.<org.apache.camel.processor.ThroughputLogger: java.lang.Long groupInterval>;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
interfaceinvoke v.<java.util.concurrent.ScheduledExecutorService: java.util.concurrent.ScheduledFuture scheduleAtFixedRate(java.lang.Runnable,long,long,java.util.concurrent.TimeUnit)>(v, v, v, v);
label:
return;
}
public void doStop() throws java.lang.Exception
{
org.apache.camel.CamelContext v;
org.apache.camel.processor.ThroughputLogger v;
java.util.concurrent.ScheduledExecutorService v, v;
org.apache.camel.spi.ExecutorServiceManager v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v = v.<org.apache.camel.processor.ThroughputLogger: java.util.concurrent.ScheduledExecutorService logSchedulerService>;
if v == null goto label;
v = v.<org.apache.camel.processor.ThroughputLogger: org.apache.camel.CamelContext camelContext>;
v = interfaceinvoke v.<org.apache.camel.CamelContext: org.apache.camel.spi.ExecutorServiceManager getExecutorServiceManager()>();
v = v.<org.apache.camel.processor.ThroughputLogger: java.util.concurrent.ScheduledExecutorService logSchedulerService>;
interfaceinvoke v.<org.apache.camel.spi.ExecutorServiceManager: void shutdown(java.util.concurrent.ExecutorService)>(v);
v.<org.apache.camel.processor.ThroughputLogger: java.util.concurrent.ScheduledExecutorService logSchedulerService> = null;
label:
return;
}
protected java.lang.String createLogMessage(org.apache.camel.Exchange, int)
{
long v, v, v, v, v, v, v;
org.apache.camel.Exchange v;
java.lang.Integer v;
java.text.NumberFormat v, v;
byte v;
int v, v;
java.lang.String v, v, v, v;
double v, v, v, v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v := @parameter: org.apache.camel.Exchange;
v := @parameter: int;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v.<org.apache.camel.processor.ThroughputLogger: long groupStartTime>;
v = v cmp 0L;
if v != 0 goto label;
v = v.<org.apache.camel.processor.ThroughputLogger: long startTime>;
v.<org.apache.camel.processor.ThroughputLogger: long groupStartTime> = v;
label:
v = v.<org.apache.camel.processor.ThroughputLogger: java.lang.Integer groupSize>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v.<org.apache.camel.processor.ThroughputLogger: long groupStartTime>;
v = virtualinvoke v.<org.apache.camel.processor.ThroughputLogger: double messagesPerSecond(long,long,long)>(v, v, v);
v.<org.apache.camel.processor.ThroughputLogger: double rate> = v;
v = v.<org.apache.camel.processor.ThroughputLogger: long startTime>;
v = virtualinvoke v.<org.apache.camel.processor.ThroughputLogger: double messagesPerSecond(long,long,long)>(v, v, v);
v.<org.apache.camel.processor.ThroughputLogger: double average> = v;
v = v.<org.apache.camel.processor.ThroughputLogger: long groupStartTime>;
v = v - v;
v.<org.apache.camel.processor.ThroughputLogger: long groupStartTime> = v;
v = virtualinvoke v.<org.apache.camel.processor.ThroughputLogger: java.lang.String getAction()>();
v = v.<org.apache.camel.processor.ThroughputLogger: java.text.NumberFormat numberFormat>;
v = v.<org.apache.camel.processor.ThroughputLogger: double rate>;
v = virtualinvoke v.<java.text.NumberFormat: java.lang.String format(double)>(v);
v = v.<org.apache.camel.processor.ThroughputLogger: java.text.NumberFormat numberFormat>;
v = v.<org.apache.camel.processor.ThroughputLogger: double average>;
v = virtualinvoke v.<java.text.NumberFormat: java.lang.String format(double)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int,long,java.lang.String,java.lang.String)>(v, v, 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[])>("\u0001: \u messages so far. Last group took: \u millis which is: \u messages per second. average: \u0001");
return v;
}
protected void createGroupIntervalLogMessage()
{
long v, v, v, v, v, v, v, v, v, v, v;
java.text.NumberFormat v, v;
byte v, v, v;
java.util.concurrent.atomic.AtomicInteger v;
org.apache.camel.util.CamelLogger v;
int v;
java.lang.String v, v, v, v, v;
boolean v;
double v, v, v, v;
org.apache.camel.processor.ThroughputLogger v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v = v.<org.apache.camel.processor.ThroughputLogger: long startTime>;
v = v cmp 0L;
if v != 0 goto label;
return;
label:
v = v.<org.apache.camel.processor.ThroughputLogger: java.util.concurrent.atomic.AtomicInteger receivedCounter>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
v = v.<org.apache.camel.processor.ThroughputLogger: boolean groupActiveOnly>;
if v == 0 goto label;
v = v.<org.apache.camel.processor.ThroughputLogger: long groupReceivedCount>;
v = v cmp v;
if v != 0 goto label;
return;
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v.<org.apache.camel.processor.ThroughputLogger: long groupStartTime>;
v = v cmp 0L;
if v != 0 goto label;
v = v.<org.apache.camel.processor.ThroughputLogger: long startTime>;
v.<org.apache.camel.processor.ThroughputLogger: long groupStartTime> = v;
label:
v = v.<org.apache.camel.processor.ThroughputLogger: long groupStartTime>;
v = v - v;
v = v.<org.apache.camel.processor.ThroughputLogger: long groupReceivedCount>;
v = v - v;
v = v.<org.apache.camel.processor.ThroughputLogger: long groupStartTime>;
v = virtualinvoke v.<org.apache.camel.processor.ThroughputLogger: double messagesPerSecond(long,long,long)>(v, v, v);
v.<org.apache.camel.processor.ThroughputLogger: double rate> = v;
v = v.<org.apache.camel.processor.ThroughputLogger: long startTime>;
v = virtualinvoke v.<org.apache.camel.processor.ThroughputLogger: double messagesPerSecond(long,long,long)>(v, v, v);
v.<org.apache.camel.processor.ThroughputLogger: double average> = v;
v.<org.apache.camel.processor.ThroughputLogger: long groupStartTime> = v;
v.<org.apache.camel.processor.ThroughputLogger: long groupReceivedCount> = v;
v = virtualinvoke v.<org.apache.camel.processor.ThroughputLogger: java.lang.String getAction()>();
v = v.<org.apache.camel.processor.ThroughputLogger: java.text.NumberFormat numberFormat>;
v = v.<org.apache.camel.processor.ThroughputLogger: double rate>;
v = virtualinvoke v.<java.text.NumberFormat: java.lang.String format(double)>(v);
v = v.<org.apache.camel.processor.ThroughputLogger: java.text.NumberFormat numberFormat>;
v = v.<org.apache.camel.processor.ThroughputLogger: double average>;
v = virtualinvoke v.<java.text.NumberFormat: java.lang.String format(double)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,long,int,long,java.lang.String,java.lang.String)>(v, v, v, 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[])>("\u0001: \u new messages, with total \u so far. Last group took: \u millis which is: \u messages per second. average: \u0001");
v.<org.apache.camel.processor.ThroughputLogger: java.lang.String lastLogMessage> = v;
v = v.<org.apache.camel.processor.ThroughputLogger: org.apache.camel.util.CamelLogger log>;
v = v.<org.apache.camel.processor.ThroughputLogger: java.lang.String lastLogMessage>;
virtualinvoke v.<org.apache.camel.util.CamelLogger: void log(java.lang.String)>(v);
return;
}
protected double messagesPerSecond(long, long, long)
{
org.apache.camel.processor.ThroughputLogger v;
long v, v, v, v;
double v, v;
v := @this: org.apache.camel.processor.ThroughputLogger;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v = v * 1000.0;
v = v - v;
v = v / v;
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/processor/ThroughputLogger;");
<org.apache.camel.processor.ThroughputLogger: org.slf4j.Logger LOG> = v;
return;
}
}