public final class org.apache.camel.processor.UnitOfWorkProducer extends java.lang.Object implements org.apache.camel.Producer
{
private final org.apache.camel.Producer producer;
private final org.apache.camel.AsyncProcessor processor;
public void <init>(org.apache.camel.Producer)
{
org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice v;
org.apache.camel.Producer v;
org.apache.camel.processor.CamelInternalProcessor v;
org.apache.camel.processor.UnitOfWorkProducer v;
v := @this: org.apache.camel.processor.UnitOfWorkProducer;
v := @parameter: org.apache.camel.Producer;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.camel.processor.UnitOfWorkProducer: org.apache.camel.Producer producer> = v;
v = new org.apache.camel.processor.CamelInternalProcessor;
specialinvoke v.<org.apache.camel.processor.CamelInternalProcessor: void <init>(org.apache.camel.Processor)>(v);
v = new org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice;
specialinvoke v.<org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice: void <init>(org.apache.camel.spi.RouteContext)>(null);
virtualinvoke v.<org.apache.camel.processor.CamelInternalProcessor: void addAdvice(org.apache.camel.processor.CamelInternalProcessorAdvice)>(v);
v.<org.apache.camel.processor.UnitOfWorkProducer: org.apache.camel.AsyncProcessor processor> = v;
return;
}
public org.apache.camel.Endpoint getEndpoint()
{
org.apache.camel.Endpoint v;
org.apache.camel.Producer v;
org.apache.camel.processor.UnitOfWorkProducer v;
v := @this: org.apache.camel.processor.UnitOfWorkProducer;
v = v.<org.apache.camel.processor.UnitOfWorkProducer: org.apache.camel.Producer producer>;
v = interfaceinvoke v.<org.apache.camel.Producer: org.apache.camel.Endpoint getEndpoint()>();
return v;
}
public org.apache.camel.Exchange createExchange()
{
org.apache.camel.Exchange v;
org.apache.camel.Producer v;
org.apache.camel.processor.UnitOfWorkProducer v;
v := @this: org.apache.camel.processor.UnitOfWorkProducer;
v = v.<org.apache.camel.processor.UnitOfWorkProducer: org.apache.camel.Producer producer>;
v = interfaceinvoke v.<org.apache.camel.Producer: org.apache.camel.Exchange createExchange()>();
return v;
}
public org.apache.camel.Exchange createExchange(org.apache.camel.ExchangePattern)
{
org.apache.camel.Exchange v;
org.apache.camel.Producer v;
org.apache.camel.processor.UnitOfWorkProducer v;
org.apache.camel.ExchangePattern v;
v := @this: org.apache.camel.processor.UnitOfWorkProducer;
v := @parameter: org.apache.camel.ExchangePattern;
v = v.<org.apache.camel.processor.UnitOfWorkProducer: org.apache.camel.Producer producer>;
v = interfaceinvoke v.<org.apache.camel.Producer: org.apache.camel.Exchange createExchange(org.apache.camel.ExchangePattern)>(v);
return v;
}
public org.apache.camel.Exchange createExchange(org.apache.camel.Exchange)
{
org.apache.camel.Exchange v, v;
org.apache.camel.Producer v;
org.apache.camel.processor.UnitOfWorkProducer v;
v := @this: org.apache.camel.processor.UnitOfWorkProducer;
v := @parameter: org.apache.camel.Exchange;
v = v.<org.apache.camel.processor.UnitOfWorkProducer: org.apache.camel.Producer producer>;
v = interfaceinvoke v.<org.apache.camel.Producer: org.apache.camel.Exchange createExchange(org.apache.camel.Exchange)>(v);
return v;
}
public void process(org.apache.camel.Exchange) throws java.lang.Exception
{
org.apache.camel.AsyncProcessor v;
org.apache.camel.Exchange v;
org.apache.camel.processor.UnitOfWorkProducer v;
v := @this: org.apache.camel.processor.UnitOfWorkProducer;
v := @parameter: org.apache.camel.Exchange;
v = v.<org.apache.camel.processor.UnitOfWorkProducer: org.apache.camel.AsyncProcessor processor>;
staticinvoke <org.apache.camel.util.AsyncProcessorHelper: void process(org.apache.camel.AsyncProcessor,org.apache.camel.Exchange)>(v, v);
return;
}
public void start() throws java.lang.Exception
{
org.apache.camel.AsyncProcessor v;
org.apache.camel.processor.UnitOfWorkProducer v;
v := @this: org.apache.camel.processor.UnitOfWorkProducer;
v = v.<org.apache.camel.processor.UnitOfWorkProducer: org.apache.camel.AsyncProcessor processor>;
staticinvoke <org.apache.camel.util.ServiceHelper: void startService(java.lang.Object)>(v);
return;
}
public void stop() throws java.lang.Exception
{
org.apache.camel.AsyncProcessor v;
org.apache.camel.processor.UnitOfWorkProducer v;
v := @this: org.apache.camel.processor.UnitOfWorkProducer;
v = v.<org.apache.camel.processor.UnitOfWorkProducer: org.apache.camel.AsyncProcessor processor>;
staticinvoke <org.apache.camel.util.ServiceHelper: void stopService(java.lang.Object)>(v);
return;
}
public boolean isSingleton()
{
org.apache.camel.Producer v;
org.apache.camel.processor.UnitOfWorkProducer v;
boolean v;
v := @this: org.apache.camel.processor.UnitOfWorkProducer;
v = v.<org.apache.camel.processor.UnitOfWorkProducer: org.apache.camel.Producer producer>;
v = interfaceinvoke v.<org.apache.camel.Producer: boolean isSingleton()>();
return v;
}
public java.lang.String toString()
{
java.lang.String v;
org.apache.camel.Producer v;
org.apache.camel.processor.UnitOfWorkProducer v;
v := @this: org.apache.camel.processor.UnitOfWorkProducer;
v = v.<org.apache.camel.processor.UnitOfWorkProducer: org.apache.camel.Producer producer>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.camel.Producer)>(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[])>("UnitOfWork(\u)");
return v;
}
}