public class org.apache.camel.processor.interceptor.StreamCachingInterceptor extends org.apache.camel.processor.DelegateAsyncProcessor
{
public void <init>()
{
org.apache.camel.processor.interceptor.StreamCachingInterceptor v;
v := @this: org.apache.camel.processor.interceptor.StreamCachingInterceptor;
specialinvoke v.<org.apache.camel.processor.DelegateAsyncProcessor: void <init>()>();
return;
}
public void <init>(org.apache.camel.Processor)
{
org.apache.camel.Processor v;
org.apache.camel.processor.interceptor.StreamCachingInterceptor v;
v := @this: org.apache.camel.processor.interceptor.StreamCachingInterceptor;
v := @parameter: org.apache.camel.Processor;
specialinvoke v.<org.apache.camel.processor.DelegateAsyncProcessor: void <init>(org.apache.camel.Processor)>(v);
return;
}
public java.lang.String toString()
{
org.apache.camel.AsyncProcessor v;
org.apache.camel.processor.interceptor.StreamCachingInterceptor v;
java.lang.String v;
v := @this: org.apache.camel.processor.interceptor.StreamCachingInterceptor;
v = v.<org.apache.camel.processor.interceptor.StreamCachingInterceptor: org.apache.camel.AsyncProcessor processor>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.camel.AsyncProcessor)>(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[])>("StreamCachingInterceptor[\u]");
return v;
}
public boolean process(org.apache.camel.Exchange, org.apache.camel.AsyncCallback)
{
org.apache.camel.Message v, v, v;
org.apache.camel.AsyncCallback v;
org.apache.camel.Exchange v;
org.apache.camel.AsyncProcessor v;
java.lang.Object v;
org.apache.camel.processor.interceptor.StreamCachingInterceptor v;
boolean v;
v := @this: org.apache.camel.processor.interceptor.StreamCachingInterceptor;
v := @parameter: org.apache.camel.Exchange;
v := @parameter: org.apache.camel.AsyncCallback;
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.Message getIn()>();
v = interfaceinvoke v.<org.apache.camel.Message: java.lang.Object getBody(java.lang.Class)>(class "Lorg/apache/camel/StreamCache;");
if v == null goto label;
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.Message getIn()>();
interfaceinvoke v.<org.apache.camel.Message: void setBody(java.lang.Object)>(v);
label:
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.Message getIn()>();
staticinvoke <org.apache.camel.util.MessageHelper: void resetStreamCache(org.apache.camel.Message)>(v);
v = v.<org.apache.camel.processor.interceptor.StreamCachingInterceptor: org.apache.camel.AsyncProcessor processor>;
v = interfaceinvoke v.<org.apache.camel.AsyncProcessor: boolean process(org.apache.camel.Exchange,org.apache.camel.AsyncCallback)>(v, v);
return v;
}
}