public class org.apache.camel.component.saga.SagaEndpoint extends org.apache.camel.impl.DefaultEndpoint
{
private final org.apache.camel.component.saga.SagaEndpoint$SagaEndpointAction action;
public void <init>(java.lang.String, org.apache.camel.component.saga.SagaComponent, java.lang.String)
{
org.apache.camel.component.saga.SagaComponent v;
org.apache.camel.component.saga.SagaEndpoint v;
org.apache.camel.component.saga.SagaEndpoint$SagaEndpointAction v;
java.lang.Object v;
java.lang.String v, v, v;
v := @this: org.apache.camel.component.saga.SagaEndpoint;
v := @parameter: java.lang.String;
v := @parameter: org.apache.camel.component.saga.SagaComponent;
v := @parameter: java.lang.String;
specialinvoke v.<org.apache.camel.impl.DefaultEndpoint: void <init>(java.lang.String,org.apache.camel.Component)>(v, v);
v = staticinvoke <org.apache.camel.util.ObjectHelper: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "action");
v = virtualinvoke v.<java.lang.String: java.lang.String toUpperCase()>();
v = staticinvoke <org.apache.camel.component.saga.SagaEndpoint$SagaEndpointAction: org.apache.camel.component.saga.SagaEndpoint$SagaEndpointAction valueOf(java.lang.String)>(v);
v.<org.apache.camel.component.saga.SagaEndpoint: org.apache.camel.component.saga.SagaEndpoint$SagaEndpointAction action> = v;
return;
}
public org.apache.camel.Producer createProducer() throws java.lang.Exception
{
java.lang.IllegalStateException v;
org.apache.camel.component.saga.SagaEndpoint v;
org.apache.camel.component.saga.SagaProducer v, v;
org.apache.camel.component.saga.SagaEndpoint$SagaEndpointAction v, v, v, v, v;
java.lang.String v;
boolean v, v;
v := @this: org.apache.camel.component.saga.SagaEndpoint;
v = <org.apache.camel.component.saga.SagaEndpoint$SagaEndpointAction: org.apache.camel.component.saga.SagaEndpoint$SagaEndpointAction COMPLETE>;
v = v.<org.apache.camel.component.saga.SagaEndpoint: org.apache.camel.component.saga.SagaEndpoint$SagaEndpointAction action>;
v = virtualinvoke v.<org.apache.camel.component.saga.SagaEndpoint$SagaEndpointAction: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = new org.apache.camel.component.saga.SagaProducer;
specialinvoke v.<org.apache.camel.component.saga.SagaProducer: void <init>(org.apache.camel.component.saga.SagaEndpoint,boolean)>(v, 1);
return v;
label:
v = <org.apache.camel.component.saga.SagaEndpoint$SagaEndpointAction: org.apache.camel.component.saga.SagaEndpoint$SagaEndpointAction COMPENSATE>;
v = v.<org.apache.camel.component.saga.SagaEndpoint: org.apache.camel.component.saga.SagaEndpoint$SagaEndpointAction action>;
v = virtualinvoke v.<org.apache.camel.component.saga.SagaEndpoint$SagaEndpointAction: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = new org.apache.camel.component.saga.SagaProducer;
specialinvoke v.<org.apache.camel.component.saga.SagaProducer: void <init>(org.apache.camel.component.saga.SagaEndpoint,boolean)>(v, 0);
return v;
label:
v = new java.lang.IllegalStateException;
v = v.<org.apache.camel.component.saga.SagaEndpoint: org.apache.camel.component.saga.SagaEndpoint$SagaEndpointAction action>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.camel.component.saga.SagaEndpoint$SagaEndpointAction)>(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[])>("Unsupported action \'\u0001\' in saga endpoint");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
}
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor) throws java.lang.Exception
{
java.lang.UnsupportedOperationException v;
org.apache.camel.Processor v;
org.apache.camel.component.saga.SagaEndpoint v;
v := @this: org.apache.camel.component.saga.SagaEndpoint;
v := @parameter: org.apache.camel.Processor;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("Consumer not allowed for saga endpoint");
throw v;
}
public boolean isSingleton()
{
org.apache.camel.component.saga.SagaEndpoint v;
v := @this: org.apache.camel.component.saga.SagaEndpoint;
return 1;
}
}