public class org.apache.camel.spring.spi.TransactionErrorHandlerBuilder extends org.apache.camel.builder.DefaultErrorHandlerBuilder
{
private static final org.slf4j.Logger LOG;
private static final java.lang.String PROPAGATION_REQUIRED;
private org.springframework.transaction.support.TransactionTemplate transactionTemplate;
private org.apache.camel.LoggingLevel rollbackLoggingLevel;
public void <init>()
{
org.apache.camel.LoggingLevel v;
org.apache.camel.spring.spi.TransactionErrorHandlerBuilder v;
v := @this: org.apache.camel.spring.spi.TransactionErrorHandlerBuilder;
specialinvoke v.<org.apache.camel.builder.DefaultErrorHandlerBuilder: void <init>()>();
v = <org.apache.camel.LoggingLevel: org.apache.camel.LoggingLevel WARN>;
v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.apache.camel.LoggingLevel rollbackLoggingLevel> = v;
return;
}
public org.springframework.transaction.support.TransactionTemplate getTransactionTemplate()
{
org.apache.camel.spring.spi.TransactionErrorHandlerBuilder v;
org.springframework.transaction.support.TransactionTemplate v;
v := @this: org.apache.camel.spring.spi.TransactionErrorHandlerBuilder;
v = v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.springframework.transaction.support.TransactionTemplate transactionTemplate>;
return v;
}
public boolean supportTransacted()
{
org.apache.camel.spring.spi.TransactionErrorHandlerBuilder v;
v := @this: org.apache.camel.spring.spi.TransactionErrorHandlerBuilder;
return 1;
}
public org.apache.camel.Processor createErrorHandler(org.apache.camel.spi.RouteContext, org.apache.camel.Processor) throws java.lang.Exception
{
org.apache.camel.spring.spi.TransactionErrorHandler v;
org.apache.camel.processor.exceptionpolicy.ExceptionPolicyStrategy v;
java.lang.Integer v, v;
org.apache.camel.spi.TransactedPolicy v, v;
org.apache.camel.Predicate v;
org.apache.camel.util.CamelLogger v;
java.util.Map v, v, v;
org.apache.camel.spring.spi.TransactionErrorHandlerBuilder v;
boolean v, v, v, v;
org.apache.camel.LoggingLevel v;
java.util.Collection v, v, v;
org.apache.camel.spi.RouteContext v;
org.apache.camel.Processor v, v, v;
int v, v, v, v, v;
java.util.concurrent.ScheduledExecutorService v;
org.apache.camel.CamelContext v, v, v;
org.slf4j.Logger v, v, v, v, v, v;
java.util.Iterator v, v, v;
org.apache.camel.processor.RedeliveryPolicy v;
org.springframework.transaction.support.TransactionTemplate v, v, v, v, v, v, v, v, v, v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.camel.spring.spi.TransactionErrorHandlerBuilder;
v := @parameter: org.apache.camel.spi.RouteContext;
v := @parameter: org.apache.camel.Processor;
v = v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.springframework.transaction.support.TransactionTemplate transactionTemplate>;
if v != null goto label;
v = <org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("No TransactionTemplate configured on TransactionErrorHandlerBuilder. Will try find it in the registry.");
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: java.util.Map lookupByType(java.lang.Class)>(class "Lorg/apache/camel/spi/TransactedPolicy;");
if v == null goto label;
v = interfaceinvoke v.<java.util.Map: int size()>();
if v != 1 goto label;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v instanceof org.apache.camel.spring.spi.SpringTransactionPolicy;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.camel.spring.spi.SpringTransactionPolicy: org.springframework.transaction.support.TransactionTemplate getTransactionTemplate()>();
v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.springframework.transaction.support.TransactionTemplate transactionTemplate> = v;
label:
v = v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.springframework.transaction.support.TransactionTemplate transactionTemplate>;
if v != null goto label;
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: java.lang.Object lookup(java.lang.String,java.lang.Class)>("PROPAGATION_REQUIRED", class "Lorg/apache/camel/spi/TransactedPolicy;");
v = v instanceof org.apache.camel.spring.spi.SpringTransactionPolicy;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.camel.spring.spi.SpringTransactionPolicy: org.springframework.transaction.support.TransactionTemplate getTransactionTemplate()>();
v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.springframework.transaction.support.TransactionTemplate transactionTemplate> = v;
label:
v = v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.springframework.transaction.support.TransactionTemplate transactionTemplate>;
if v != null goto label;
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: java.util.Map lookupByType(java.lang.Class)>(class "Lorg/springframework/transaction/support/TransactionTemplate;");
if v == null goto label;
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
if v == 0 goto label;
label:
v = <org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String)>("No TransactionTemplate found in registry.");
goto label;
label:
v = interfaceinvoke v.<java.util.Map: int size()>();
if v != 1 goto label;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.springframework.transaction.support.TransactionTemplate transactionTemplate> = v;
goto label;
label:
v = <org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<java.util.Map: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Found {} TransactionTemplate in registry. Cannot determine which one to use. Please configure a TransactionTemplate on the TransactionErrorHandlerBuilder", v);
label:
v = v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.springframework.transaction.support.TransactionTemplate transactionTemplate>;
if v != null goto label;
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: java.util.Map lookupByType(java.lang.Class)>(class "Lorg/springframework/transaction/PlatformTransactionManager;");
if v == null goto label;
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
if v == 0 goto label;
label:
v = <org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String)>("No PlatformTransactionManager found in registry.");
goto label;
label:
v = interfaceinvoke v.<java.util.Map: int size()>();
if v != 1 goto label;
v = new org.springframework.transaction.support.TransactionTemplate;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
specialinvoke v.<org.springframework.transaction.support.TransactionTemplate: void <init>(org.springframework.transaction.PlatformTransactionManager)>(v);
v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.springframework.transaction.support.TransactionTemplate transactionTemplate> = v;
goto label;
label:
v = <org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<java.util.Map: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Found {} PlatformTransactionManager in registry. Cannot determine which one to use for TransactionTemplate. Please configure a TransactionTemplate on the TransactionErrorHandlerBuilder", v);
label:
v = v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.springframework.transaction.support.TransactionTemplate transactionTemplate>;
if v == null goto label;
v = <org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.slf4j.Logger LOG>;
v = v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.springframework.transaction.support.TransactionTemplate transactionTemplate>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Found TransactionTemplate in registry to use: {}", v);
label:
v = v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.springframework.transaction.support.TransactionTemplate transactionTemplate>;
staticinvoke <org.apache.camel.util.ObjectHelper: java.lang.Object notNull(java.lang.Object,java.lang.String,java.lang.Object)>(v, "transactionTemplate", v);
v = new org.apache.camel.spring.spi.TransactionErrorHandler;
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: org.apache.camel.CamelContext getCamelContext()>();
v = virtualinvoke v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.apache.camel.util.CamelLogger getLogger()>();
v = virtualinvoke v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.apache.camel.Processor getOnRedelivery()>();
v = virtualinvoke v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.apache.camel.processor.RedeliveryPolicy getRedeliveryPolicy()>();
v = virtualinvoke v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.apache.camel.processor.exceptionpolicy.ExceptionPolicyStrategy getExceptionPolicyStrategy()>();
v = v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.springframework.transaction.support.TransactionTemplate transactionTemplate>;
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: org.apache.camel.CamelContext getCamelContext()>();
v = virtualinvoke v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: 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.spring.spi.TransactionErrorHandlerBuilder: java.util.concurrent.ScheduledExecutorService getExecutorService(org.apache.camel.CamelContext)>(v);
v = virtualinvoke v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.apache.camel.LoggingLevel getRollbackLoggingLevel()>();
v = virtualinvoke v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.apache.camel.Processor getOnExceptionOccurred()>();
specialinvoke v.<org.apache.camel.spring.spi.TransactionErrorHandler: 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.springframework.transaction.support.TransactionTemplate,org.apache.camel.Predicate,java.util.concurrent.ScheduledExecutorService,org.apache.camel.LoggingLevel,org.apache.camel.Processor)>(v, v, v, v, v, v, v, v, v, v, v);
virtualinvoke v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: void configure(org.apache.camel.spi.RouteContext,org.apache.camel.processor.ErrorHandler)>(v, v);
return v;
}
public void setTransactionTemplate(org.springframework.transaction.support.TransactionTemplate)
{
org.apache.camel.spring.spi.TransactionErrorHandlerBuilder v;
org.springframework.transaction.support.TransactionTemplate v;
v := @this: org.apache.camel.spring.spi.TransactionErrorHandlerBuilder;
v := @parameter: org.springframework.transaction.support.TransactionTemplate;
v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.springframework.transaction.support.TransactionTemplate transactionTemplate> = v;
return;
}
public void setSpringTransactionPolicy(org.apache.camel.spring.spi.SpringTransactionPolicy)
{
org.apache.camel.spring.spi.SpringTransactionPolicy v;
org.apache.camel.spring.spi.TransactionErrorHandlerBuilder v;
org.springframework.transaction.support.TransactionTemplate v;
v := @this: org.apache.camel.spring.spi.TransactionErrorHandlerBuilder;
v := @parameter: org.apache.camel.spring.spi.SpringTransactionPolicy;
v = virtualinvoke v.<org.apache.camel.spring.spi.SpringTransactionPolicy: org.springframework.transaction.support.TransactionTemplate getTransactionTemplate()>();
v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.springframework.transaction.support.TransactionTemplate transactionTemplate> = v;
return;
}
public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager)
{
org.springframework.transaction.PlatformTransactionManager v;
org.apache.camel.spring.spi.TransactionErrorHandlerBuilder v;
org.springframework.transaction.support.TransactionTemplate v;
v := @this: org.apache.camel.spring.spi.TransactionErrorHandlerBuilder;
v := @parameter: org.springframework.transaction.PlatformTransactionManager;
v = new org.springframework.transaction.support.TransactionTemplate;
specialinvoke v.<org.springframework.transaction.support.TransactionTemplate: void <init>(org.springframework.transaction.PlatformTransactionManager)>(v);
v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.springframework.transaction.support.TransactionTemplate transactionTemplate> = v;
return;
}
public org.apache.camel.LoggingLevel getRollbackLoggingLevel()
{
org.apache.camel.LoggingLevel v;
org.apache.camel.spring.spi.TransactionErrorHandlerBuilder v;
v := @this: org.apache.camel.spring.spi.TransactionErrorHandlerBuilder;
v = v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.apache.camel.LoggingLevel rollbackLoggingLevel>;
return v;
}
public void setRollbackLoggingLevel(org.apache.camel.LoggingLevel)
{
org.apache.camel.LoggingLevel v;
org.apache.camel.spring.spi.TransactionErrorHandlerBuilder v;
v := @this: org.apache.camel.spring.spi.TransactionErrorHandlerBuilder;
v := @parameter: org.apache.camel.LoggingLevel;
v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.apache.camel.LoggingLevel rollbackLoggingLevel> = v;
return;
}
public org.apache.camel.spring.spi.TransactionErrorHandlerBuilder rollbackLoggingLevel(org.apache.camel.LoggingLevel)
{
org.apache.camel.LoggingLevel v;
org.apache.camel.spring.spi.TransactionErrorHandlerBuilder v;
v := @this: org.apache.camel.spring.spi.TransactionErrorHandlerBuilder;
v := @parameter: org.apache.camel.LoggingLevel;
virtualinvoke v.<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: void setRollbackLoggingLevel(org.apache.camel.LoggingLevel)>(v);
return v;
}
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.spring.spi.TransactionErrorHandlerBuilder v;
v := @this: org.apache.camel.spring.spi.TransactionErrorHandlerBuilder;
v = new org.apache.camel.util.CamelLogger;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/camel/spring/spi/TransactionErrorHandler;");
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()
{
org.apache.camel.spring.spi.TransactionErrorHandlerBuilder v;
v := @this: org.apache.camel.spring.spi.TransactionErrorHandlerBuilder;
return "TransactionErrorHandlerBuilder";
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/camel/spring/spi/TransactionErrorHandlerBuilder;");
<org.apache.camel.spring.spi.TransactionErrorHandlerBuilder: org.slf4j.Logger LOG> = v;
return;
}
}