public class org.apache.camel.builder.DeadLetterChannelBuilder extends org.apache.camel.builder.DefaultErrorHandlerBuilder
{
public void <init>()
{
org.apache.camel.builder.DeadLetterChannelBuilder v;
v := @this: org.apache.camel.builder.DeadLetterChannelBuilder;
specialinvoke v.<org.apache.camel.builder.DefaultErrorHandlerBuilder: void <init>()>();
return;
}
public void <init>(org.apache.camel.Endpoint)
{
org.apache.camel.Endpoint v;
org.apache.camel.processor.RedeliveryPolicy v;
org.apache.camel.builder.DeadLetterChannelBuilder v;
v := @this: org.apache.camel.builder.DeadLetterChannelBuilder;
v := @parameter: org.apache.camel.Endpoint;
specialinvoke v.<org.apache.camel.builder.DefaultErrorHandlerBuilder: void <init>()>();
virtualinvoke v.<org.apache.camel.builder.DeadLetterChannelBuilder: void setDeadLetter(org.apache.camel.Endpoint)>(v);
v = virtualinvoke v.<org.apache.camel.builder.DeadLetterChannelBuilder: org.apache.camel.processor.RedeliveryPolicy getRedeliveryPolicy()>();
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setLogExhausted(boolean)>(0);
return;
}
public void <init>(java.lang.String)
{
java.lang.String v;
org.apache.camel.builder.DeadLetterChannelBuilder v;
v := @this: org.apache.camel.builder.DeadLetterChannelBuilder;
v := @parameter: java.lang.String;
specialinvoke v.<org.apache.camel.builder.DefaultErrorHandlerBuilder: void <init>()>();
virtualinvoke v.<org.apache.camel.builder.DeadLetterChannelBuilder: void setDeadLetterUri(java.lang.String)>(v);
return;
}
public org.apache.camel.Processor createErrorHandler(org.apache.camel.spi.RouteContext, org.apache.camel.Processor) throws java.lang.Exception
{
org.apache.camel.processor.exceptionpolicy.ExceptionPolicyStrategy v;
org.apache.camel.Processor v, v, v, v, v;
org.apache.camel.Predicate v;
org.apache.camel.util.CamelLogger v;
java.util.concurrent.ScheduledExecutorService v;
java.lang.String v;
boolean v, v;
org.apache.camel.builder.DeadLetterChannelBuilder v;
org.apache.camel.CamelContext v, v, v;
org.apache.camel.processor.DeadLetterChannel v;
org.apache.camel.processor.RedeliveryPolicy v;
org.apache.camel.spi.RouteContext v;
v := @this: org.apache.camel.builder.DeadLetterChannelBuilder;
v := @parameter: org.apache.camel.spi.RouteContext;
v := @parameter: org.apache.camel.Processor;
virtualinvoke v.<org.apache.camel.builder.DeadLetterChannelBuilder: void validateDeadLetterUri(org.apache.camel.spi.RouteContext)>(v);
v = new org.apache.camel.processor.DeadLetterChannel;
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: org.apache.camel.CamelContext getCamelContext()>();
v = virtualinvoke v.<org.apache.camel.builder.DeadLetterChannelBuilder: org.apache.camel.util.CamelLogger getLogger()>();
v = virtualinvoke v.<org.apache.camel.builder.DeadLetterChannelBuilder: org.apache.camel.Processor getOnRedelivery()>();
v = virtualinvoke v.<org.apache.camel.builder.DeadLetterChannelBuilder: org.apache.camel.processor.RedeliveryPolicy getRedeliveryPolicy()>();
v = virtualinvoke v.<org.apache.camel.builder.DeadLetterChannelBuilder: org.apache.camel.processor.exceptionpolicy.ExceptionPolicyStrategy getExceptionPolicyStrategy()>();
v = virtualinvoke v.<org.apache.camel.builder.DeadLetterChannelBuilder: org.apache.camel.Processor getFailureProcessor()>();
v = virtualinvoke v.<org.apache.camel.builder.DeadLetterChannelBuilder: java.lang.String getDeadLetterUri()>();
v = virtualinvoke v.<org.apache.camel.builder.DeadLetterChannelBuilder: boolean isDeadLetterHandleNewException()>();
v = virtualinvoke v.<org.apache.camel.builder.DeadLetterChannelBuilder: boolean isUseOriginalMessage()>();
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: org.apache.camel.CamelContext getCamelContext()>();
v = virtualinvoke v.<org.apache.camel.builder.DeadLetterChannelBuilder: org.apache.camel.Predicate getRetryWhilePolicy(org.apache.camel.CamelContext)>(v);
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: org.apache.camel.CamelContext getCamelContext()>();
v = virtualinvoke v.<org.apache.camel.builder.DeadLetterChannelBuilder: java.util.concurrent.ScheduledExecutorService getExecutorService(org.apache.camel.CamelContext)>(v);
v = virtualinvoke v.<org.apache.camel.builder.DeadLetterChannelBuilder: org.apache.camel.Processor getOnPrepareFailure()>();
v = virtualinvoke v.<org.apache.camel.builder.DeadLetterChannelBuilder: org.apache.camel.Processor getOnExceptionOccurred()>();
specialinvoke v.<org.apache.camel.processor.DeadLetterChannel: void <init>(org.apache.camel.CamelContext,org.apache.camel.Processor,org.apache.camel.util.CamelLogger,org.apache.camel.Processor,org.apache.camel.processor.RedeliveryPolicy,org.apache.camel.processor.exceptionpolicy.ExceptionPolicyStrategy,org.apache.camel.Processor,java.lang.String,boolean,boolean,org.apache.camel.Predicate,java.util.concurrent.ScheduledExecutorService,org.apache.camel.Processor,org.apache.camel.Processor)>(v, v, v, v, v, v, v, v, v, v, v, v, v, v);
virtualinvoke v.<org.apache.camel.builder.DeadLetterChannelBuilder: void configure(org.apache.camel.spi.RouteContext,org.apache.camel.processor.ErrorHandler)>(v, v);
return v;
}
public boolean supportTransacted()
{
org.apache.camel.builder.DeadLetterChannelBuilder v;
v := @this: org.apache.camel.builder.DeadLetterChannelBuilder;
return 0;
}
public org.apache.camel.builder.ErrorHandlerBuilder cloneBuilder()
{
org.apache.camel.builder.DeadLetterChannelBuilder v, v;
v := @this: org.apache.camel.builder.DeadLetterChannelBuilder;
v = new org.apache.camel.builder.DeadLetterChannelBuilder;
specialinvoke v.<org.apache.camel.builder.DeadLetterChannelBuilder: void <init>()>();
specialinvoke v.<org.apache.camel.builder.DefaultErrorHandlerBuilder: void cloneBuilder(org.apache.camel.builder.DefaultErrorHandlerBuilder)>(v);
return v;
}
public org.apache.camel.Processor getFailureProcessor()
{
org.apache.camel.Processor v, v;
org.apache.camel.processor.FatalFallbackErrorHandler v;
org.apache.camel.processor.SendProcessor v;
org.apache.camel.Endpoint v;
org.apache.camel.ExchangePattern v;
org.apache.camel.builder.DeadLetterChannelBuilder v;
v := @this: org.apache.camel.builder.DeadLetterChannelBuilder;
v = v.<org.apache.camel.builder.DeadLetterChannelBuilder: org.apache.camel.Processor failureProcessor>;
if v != null goto label;
v = new org.apache.camel.processor.SendProcessor;
v = v.<org.apache.camel.builder.DeadLetterChannelBuilder: org.apache.camel.Endpoint deadLetter>;
v = <org.apache.camel.ExchangePattern: org.apache.camel.ExchangePattern InOnly>;
specialinvoke v.<org.apache.camel.processor.SendProcessor: void <init>(org.apache.camel.Endpoint,org.apache.camel.ExchangePattern)>(v, v);
v = new org.apache.camel.processor.FatalFallbackErrorHandler;
specialinvoke v.<org.apache.camel.processor.FatalFallbackErrorHandler: void <init>(org.apache.camel.Processor,boolean)>(v, 1);
v.<org.apache.camel.builder.DeadLetterChannelBuilder: org.apache.camel.Processor failureProcessor> = v;
label:
v = v.<org.apache.camel.builder.DeadLetterChannelBuilder: org.apache.camel.Processor failureProcessor>;
return v;
}
protected void validateDeadLetterUri(org.apache.camel.spi.RouteContext)
{
org.apache.camel.CamelContext v;
org.apache.camel.NoSuchEndpointException v;
org.apache.camel.Endpoint v, v, v;
java.lang.String v, v, v;
org.apache.camel.spi.RouteContext v;
org.apache.camel.builder.DeadLetterChannelBuilder v;
v := @this: org.apache.camel.builder.DeadLetterChannelBuilder;
v := @parameter: org.apache.camel.spi.RouteContext;
v = v.<org.apache.camel.builder.DeadLetterChannelBuilder: org.apache.camel.Endpoint deadLetter>;
if v != null goto label;
v = v.<org.apache.camel.builder.DeadLetterChannelBuilder: java.lang.String deadLetterUri>;
staticinvoke <org.apache.camel.util.StringHelper: java.lang.String notEmpty(java.lang.String,java.lang.String,java.lang.Object)>(v, "deadLetterUri", v);
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: org.apache.camel.CamelContext getCamelContext()>();
v = v.<org.apache.camel.builder.DeadLetterChannelBuilder: java.lang.String deadLetterUri>;
v = interfaceinvoke v.<org.apache.camel.CamelContext: org.apache.camel.Endpoint getEndpoint(java.lang.String)>(v);
v.<org.apache.camel.builder.DeadLetterChannelBuilder: org.apache.camel.Endpoint deadLetter> = v;
v = v.<org.apache.camel.builder.DeadLetterChannelBuilder: org.apache.camel.Endpoint deadLetter>;
if v != null goto label;
v = new org.apache.camel.NoSuchEndpointException;
v = v.<org.apache.camel.builder.DeadLetterChannelBuilder: java.lang.String deadLetterUri>;
specialinvoke v.<org.apache.camel.NoSuchEndpointException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
protected org.apache.camel.util.CamelLogger createLogger()
{
org.apache.camel.LoggingLevel v;
org.slf4j.Logger v;
org.apache.camel.util.CamelLogger v;
org.apache.camel.builder.DeadLetterChannelBuilder v;
v := @this: org.apache.camel.builder.DeadLetterChannelBuilder;
v = new org.apache.camel.util.CamelLogger;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/camel/processor/DeadLetterChannel;");
v = <org.apache.camel.LoggingLevel: org.apache.camel.LoggingLevel ERROR>;
specialinvoke v.<org.apache.camel.util.CamelLogger: void <init>(org.slf4j.Logger,org.apache.camel.LoggingLevel)>(v, v);
return v;
}
public java.lang.String toString()
{
java.lang.String v, v;
org.apache.camel.builder.DeadLetterChannelBuilder v;
v := @this: org.apache.camel.builder.DeadLetterChannelBuilder;
v = v.<org.apache.camel.builder.DeadLetterChannelBuilder: java.lang.String deadLetterUri>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("DeadLetterChannelBuilder(\u)");
return v;
}
}