final class org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion extends java.lang.Object implements org.apache.camel.spi.Synchronization
{
private final java.lang.String exchangeId;
final org.apache.camel.processor.aggregate.AggregateProcessor this$0;
private void <init>(org.apache.camel.processor.aggregate.AggregateProcessor, java.lang.String)
{
java.lang.String v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion v;
v := @this: org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion;
v := @parameter: org.apache.camel.processor.aggregate.AggregateProcessor;
v := @parameter: java.lang.String;
v.<org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion: org.apache.camel.processor.aggregate.AggregateProcessor this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion: java.lang.String exchangeId> = v;
return;
}
public void onFailure(org.apache.camel.Exchange)
{
org.slf4j.Logger v;
java.util.Set v;
org.apache.camel.Exchange v;
java.lang.String v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion v;
v := @this: org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion;
v := @parameter: org.apache.camel.Exchange;
v = <org.apache.camel.processor.aggregate.AggregateProcessor: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object)>("Aggregated exchange onFailure: {}", v);
v = v.<org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion: org.apache.camel.processor.aggregate.AggregateProcessor this$0>;
v = v.<org.apache.camel.processor.aggregate.AggregateProcessor: java.util.Set inProgressCompleteExchanges>;
v = v.<org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion: java.lang.String exchangeId>;
interfaceinvoke v.<java.util.Set: boolean remove(java.lang.Object)>(v);
return;
}
public void onComplete(org.apache.camel.Exchange)
{
java.lang.Throwable v;
org.apache.camel.Exchange v;
java.util.Map v;
java.lang.String v, v, v, v;
org.apache.camel.CamelContext v;
org.apache.camel.spi.AggregationRepository v;
org.slf4j.Logger v;
java.util.Set v, v;
org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion v;
org.apache.camel.processor.aggregate.AggregateProcessor v, v, v, v;
v := @this: org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion;
v := @parameter: org.apache.camel.Exchange;
v = <org.apache.camel.processor.aggregate.AggregateProcessor: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object)>("Aggregated exchange onComplete: {}", v);
label:
v = v.<org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion: org.apache.camel.processor.aggregate.AggregateProcessor this$0>;
v = v.<org.apache.camel.processor.aggregate.AggregateProcessor: org.apache.camel.spi.AggregationRepository aggregationRepository>;
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.CamelContext getContext()>();
v = v.<org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion: java.lang.String exchangeId>;
interfaceinvoke v.<org.apache.camel.spi.AggregationRepository: void confirm(org.apache.camel.CamelContext,java.lang.String)>(v, v);
v = v.<org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion: org.apache.camel.processor.aggregate.AggregateProcessor this$0>;
v = v.<org.apache.camel.processor.aggregate.AggregateProcessor: java.util.Map redeliveryState>;
v = v.<org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion: java.lang.String exchangeId>;
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
label:
v = v.<org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion: org.apache.camel.processor.aggregate.AggregateProcessor this$0>;
v = v.<org.apache.camel.processor.aggregate.AggregateProcessor: java.util.Set inProgressCompleteExchanges>;
v = v.<org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion: java.lang.String exchangeId>;
interfaceinvoke v.<java.util.Set: boolean remove(java.lang.Object)>(v);
goto label;
label:
v := @caughtexception;
v = v.<org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion: org.apache.camel.processor.aggregate.AggregateProcessor this$0>;
v = v.<org.apache.camel.processor.aggregate.AggregateProcessor: java.util.Set inProgressCompleteExchanges>;
v = v.<org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion: java.lang.String exchangeId>;
interfaceinvoke v.<java.util.Set: boolean remove(java.lang.Object)>(v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public java.lang.String toString()
{
org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion v;
v := @this: org.apache.camel.processor.aggregate.AggregateProcessor$AggregateOnCompletion;
return "AggregateOnCompletion";
}
}