final class org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry extends java.lang.Object implements org.apache.camel.spi.AsyncProcessorAwaitManager$AwaitThread
{
private final java.lang.Thread thread;
private final org.apache.camel.Exchange exchange;
private final java.util.concurrent.CountDownLatch latch;
private final long start;
private void <init>(java.lang.Thread, org.apache.camel.Exchange, java.util.concurrent.CountDownLatch)
{
java.util.concurrent.CountDownLatch v;
org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry v;
java.lang.Thread v;
long v;
org.apache.camel.Exchange v;
v := @this: org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry;
v := @parameter: java.lang.Thread;
v := @parameter: org.apache.camel.Exchange;
v := @parameter: java.util.concurrent.CountDownLatch;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry: java.lang.Thread thread> = v;
v.<org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry: org.apache.camel.Exchange exchange> = v;
v.<org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry: java.util.concurrent.CountDownLatch latch> = v;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v.<org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry: long start> = v;
return;
}
public java.lang.Thread getBlockedThread()
{
org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry v;
java.lang.Thread v;
v := @this: org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry;
v = v.<org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry: java.lang.Thread thread>;
return v;
}
public org.apache.camel.Exchange getExchange()
{
org.apache.camel.Exchange v;
org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry v;
v := @this: org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry;
v = v.<org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry: org.apache.camel.Exchange exchange>;
return v;
}
public long getWaitDuration()
{
org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry v;
long v, v, v;
v := @this: org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v.<org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry: long start>;
v = v - v;
return v;
}
public java.lang.String getRouteId()
{
org.apache.camel.MessageHistory v;
java.lang.String v;
org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry v;
v := @this: org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry;
v = specialinvoke v.<org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry: org.apache.camel.MessageHistory getLastMessageHistory()>();
if v != null goto label;
return null;
label:
v = interfaceinvoke v.<org.apache.camel.MessageHistory: java.lang.String getRouteId()>();
return v;
}
public java.lang.String getNodeId()
{
java.lang.String v;
org.apache.camel.NamedNode v;
org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry v;
v := @this: org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry;
v = specialinvoke v.<org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry: org.apache.camel.NamedNode getNode()>();
if v != null goto label;
return null;
label:
v = interfaceinvoke v.<org.apache.camel.NamedNode: java.lang.String getId()>();
return v;
}
public java.util.concurrent.CountDownLatch getLatch()
{
java.util.concurrent.CountDownLatch v;
org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry v;
v := @this: org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry;
v = v.<org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry: java.util.concurrent.CountDownLatch latch>;
return v;
}
private org.apache.camel.NamedNode getNode()
{
org.apache.camel.MessageHistory v;
org.apache.camel.NamedNode v;
org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry v;
v := @this: org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry;
v = specialinvoke v.<org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry: org.apache.camel.MessageHistory getLastMessageHistory()>();
if v != null goto label;
return null;
label:
v = interfaceinvoke v.<org.apache.camel.MessageHistory: org.apache.camel.NamedNode getNode()>();
return v;
}
private org.apache.camel.MessageHistory getLastMessageHistory()
{
org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry v;
java.lang.Object v;
java.util.LinkedList v;
boolean v;
v := @this: org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry;
v = specialinvoke v.<org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry: java.util.LinkedList getMessageHistories()>();
if v == null goto label;
v = virtualinvoke v.<java.util.LinkedList: boolean isEmpty()>();
if v == 0 goto label;
label:
return null;
label:
v = virtualinvoke v.<java.util.LinkedList: java.lang.Object getLast()>();
return v;
}
private java.util.LinkedList getMessageHistories()
{
java.lang.Object v;
org.apache.camel.Exchange v;
org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry v;
v := @this: org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry;
v = v.<org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry: org.apache.camel.Exchange exchange>;
v = interfaceinvoke v.<org.apache.camel.Exchange: java.lang.Object getProperty(java.lang.String,java.lang.Class)>("CamelMessageHistory", class "Ljava/util/LinkedList;");
return v;
}
public java.lang.String toString()
{
org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry v;
java.lang.Thread v;
org.apache.camel.Exchange v;
java.lang.String v, v, v;
v := @this: org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry;
v = v.<org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry: java.lang.Thread thread>;
v = virtualinvoke v.<java.lang.Thread: java.lang.String getName()>();
v = v.<org.apache.camel.impl.DefaultAsyncProcessorAwaitManager$AwaitThreadEntry: org.apache.camel.Exchange exchange>;
v = interfaceinvoke v.<org.apache.camel.Exchange: java.lang.String getExchangeId()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("AwaitThreadEntry[name=\u, exchangeId=\u]");
return v;
}
}