class org.apache.camel.impl.ProducerCache$1 extends java.lang.Object implements org.apache.camel.ProducerCallback
{
final org.apache.camel.Processor val$processor;
final org.apache.camel.Endpoint val$endpoint;
final org.apache.camel.Processor val$resultProcessor;
final org.apache.camel.impl.ProducerCache this$0;
void <init>(org.apache.camel.impl.ProducerCache, org.apache.camel.Processor, org.apache.camel.Endpoint, org.apache.camel.Processor)
{
org.apache.camel.Processor v, v;
org.apache.camel.impl.ProducerCache v;
org.apache.camel.impl.ProducerCache$1 v;
org.apache.camel.Endpoint v;
v := @this: org.apache.camel.impl.ProducerCache$1;
v := @parameter: org.apache.camel.impl.ProducerCache;
v := @parameter: org.apache.camel.Processor;
v := @parameter: org.apache.camel.Endpoint;
v := @parameter: org.apache.camel.Processor;
v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.impl.ProducerCache this$0> = v;
v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.Processor val$processor> = v;
v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.Endpoint val$endpoint> = v;
v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.Processor val$resultProcessor> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public org.apache.camel.Exchange doInProducer(org.apache.camel.Producer, org.apache.camel.Exchange, org.apache.camel.ExchangePattern)
{
org.apache.camel.Endpoint v, v, v, v, v, v, v, v;
org.apache.camel.impl.ProducerCache$1 v;
boolean v, v, v, v, v;
org.apache.camel.processor.SharedCamelInternalProcessor v;
org.apache.camel.impl.ProducerCache v, v, v, v, v, v;
org.apache.camel.AsyncProcessor v;
java.lang.Throwable v, v, v;
long v, v, v;
org.apache.camel.Exchange v, v;
org.apache.camel.Processor v, v, v;
java.lang.String v;
org.apache.camel.ExchangePattern v;
org.apache.camel.CamelContext v, v, v, v;
org.slf4j.Logger v;
org.apache.camel.util.StopWatch v, v;
org.apache.camel.Producer v;
v := @this: org.apache.camel.impl.ProducerCache$1;
v := @parameter: org.apache.camel.Producer;
v := @parameter: org.apache.camel.Exchange;
v := @parameter: org.apache.camel.ExchangePattern;
if v != null goto label;
if v == null goto label;
v = interfaceinvoke v.<org.apache.camel.Producer: org.apache.camel.Endpoint getEndpoint()>();
v = interfaceinvoke v.<org.apache.camel.Endpoint: org.apache.camel.Exchange createExchange(org.apache.camel.ExchangePattern)>(v);
goto label;
label:
v = interfaceinvoke v.<org.apache.camel.Producer: org.apache.camel.Endpoint getEndpoint()>();
v = interfaceinvoke v.<org.apache.camel.Endpoint: org.apache.camel.Exchange createExchange()>();
label:
v = v;
label:
v = v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.Processor val$processor>;
if v == null goto label;
label:
v = v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.Processor val$processor>;
interfaceinvoke v.<org.apache.camel.Processor: void process(org.apache.camel.Exchange)>(v);
label:
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.camel.Exchange: void setException(java.lang.Throwable)>(v);
return v;
label:
v = <org.apache.camel.impl.ProducerCache: org.slf4j.Logger LOG>;
v = v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.Endpoint val$endpoint>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>(">>>> {} {}", v, v);
v = v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.Endpoint val$endpoint>;
v = interfaceinvoke v.<org.apache.camel.Endpoint: java.lang.String getEndpointUri()>();
interfaceinvoke v.<org.apache.camel.Exchange: void setProperty(java.lang.String,java.lang.Object)>("CamelToEndpoint", v);
v = null;
label:
v = v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.impl.ProducerCache this$0>;
v = v.<org.apache.camel.impl.ProducerCache: boolean eventNotifierEnabled>;
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.CamelContext getContext()>();
v = v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.Endpoint val$endpoint>;
v = staticinvoke <org.apache.camel.util.EventHelper: boolean notifyExchangeSending(org.apache.camel.CamelContext,org.apache.camel.Exchange,org.apache.camel.Endpoint)>(v, v, v);
if v == 0 goto label;
v = new org.apache.camel.util.StopWatch;
specialinvoke v.<org.apache.camel.util.StopWatch: void <init>()>();
v = v;
label:
v = v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.impl.ProducerCache this$0>;
v = virtualinvoke v.<org.apache.camel.impl.ProducerCache: org.apache.camel.AsyncProcessor prepareProducer(org.apache.camel.Producer)>(v);
v = v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.impl.ProducerCache this$0>;
v = v.<org.apache.camel.impl.ProducerCache: org.apache.camel.processor.SharedCamelInternalProcessor internalProcessor>;
v = v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.Processor val$resultProcessor>;
virtualinvoke v.<org.apache.camel.processor.SharedCamelInternalProcessor: void process(org.apache.camel.Exchange,org.apache.camel.AsyncProcessor,org.apache.camel.Processor)>(v, v, v);
label:
v = v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.impl.ProducerCache this$0>;
v = v.<org.apache.camel.impl.ProducerCache: boolean eventNotifierEnabled>;
if v == 0 goto label;
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.util.StopWatch: long taken()>();
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.CamelContext getContext()>();
v = v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.Endpoint val$endpoint>;
staticinvoke <org.apache.camel.util.EventHelper: boolean notifyExchangeSent(org.apache.camel.CamelContext,org.apache.camel.Exchange,org.apache.camel.Endpoint,long)>(v, v, v, v);
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.camel.Exchange: void setException(java.lang.Throwable)>(v);
label:
v = v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.impl.ProducerCache this$0>;
v = v.<org.apache.camel.impl.ProducerCache: boolean eventNotifierEnabled>;
if v == 0 goto label;
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.util.StopWatch: long taken()>();
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.CamelContext getContext()>();
v = v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.Endpoint val$endpoint>;
staticinvoke <org.apache.camel.util.EventHelper: boolean notifyExchangeSent(org.apache.camel.CamelContext,org.apache.camel.Exchange,org.apache.camel.Endpoint,long)>(v, v, v, v);
goto label;
label:
v := @caughtexception;
v = v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.impl.ProducerCache this$0>;
v = v.<org.apache.camel.impl.ProducerCache: boolean eventNotifierEnabled>;
if v == 0 goto label;
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.util.StopWatch: long taken()>();
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.CamelContext getContext()>();
v = v.<org.apache.camel.impl.ProducerCache$1: org.apache.camel.Endpoint val$endpoint>;
staticinvoke <org.apache.camel.util.EventHelper: boolean notifyExchangeSent(org.apache.camel.CamelContext,org.apache.camel.Exchange,org.apache.camel.Endpoint,long)>(v, v, v, v);
label:
throw v;
label:
return v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
}