public class org.apache.camel.processor.saga.RequiresNewSagaProcessor extends org.apache.camel.processor.saga.SagaProcessor
{
public void <init>(org.apache.camel.CamelContext, org.apache.camel.Processor, org.apache.camel.saga.CamelSagaService, org.apache.camel.model.SagaCompletionMode, org.apache.camel.saga.CamelSagaStep)
{
org.apache.camel.CamelContext v;
org.apache.camel.Processor v;
org.apache.camel.processor.saga.RequiresNewSagaProcessor v;
org.apache.camel.saga.CamelSagaService v;
org.apache.camel.saga.CamelSagaStep v;
org.apache.camel.model.SagaCompletionMode v;
v := @this: org.apache.camel.processor.saga.RequiresNewSagaProcessor;
v := @parameter: org.apache.camel.CamelContext;
v := @parameter: org.apache.camel.Processor;
v := @parameter: org.apache.camel.saga.CamelSagaService;
v := @parameter: org.apache.camel.model.SagaCompletionMode;
v := @parameter: org.apache.camel.saga.CamelSagaStep;
specialinvoke v.<org.apache.camel.processor.saga.SagaProcessor: void <init>(org.apache.camel.CamelContext,org.apache.camel.Processor,org.apache.camel.saga.CamelSagaService,org.apache.camel.model.SagaCompletionMode,org.apache.camel.saga.CamelSagaStep)>(v, v, v, v, v);
return;
}
public boolean process(org.apache.camel.Exchange, org.apache.camel.AsyncCallback)
{
org.apache.camel.processor.saga.RequiresNewSagaProcessor v;
java.util.function.BiConsumer v;
org.apache.camel.AsyncCallback v;
java.util.concurrent.CompletableFuture v;
org.apache.camel.Exchange v;
v := @this: org.apache.camel.processor.saga.RequiresNewSagaProcessor;
v := @parameter: org.apache.camel.Exchange;
v := @parameter: org.apache.camel.AsyncCallback;
v = virtualinvoke v.<org.apache.camel.processor.saga.RequiresNewSagaProcessor: java.util.concurrent.CompletableFuture getCurrentSagaCoordinator(org.apache.camel.Exchange)>(v);
v = staticinvoke <org.apache.camel.processor.saga.RequiresNewSagaProcessor$lambda_process_6__507: java.util.function.BiConsumer bootstrap$(org.apache.camel.processor.saga.RequiresNewSagaProcessor,org.apache.camel.Exchange,org.apache.camel.AsyncCallback)>(v, v, v);
virtualinvoke v.<java.util.concurrent.CompletableFuture: java.util.concurrent.CompletableFuture whenComplete(java.util.function.BiConsumer)>(v);
return 0;
}
}