public class org.apache.camel.processor.loadbalancer.LoadBalancerConsumer extends org.apache.camel.impl.DefaultConsumer
{
private final org.apache.camel.processor.loadbalancer.LoadBalancer loadBalancer;
public void <init>(org.apache.camel.Endpoint, org.apache.camel.Processor, org.apache.camel.processor.loadbalancer.LoadBalancer)
{
org.apache.camel.Processor v;
org.apache.camel.processor.loadbalancer.LoadBalancer v;
org.apache.camel.Endpoint v;
org.apache.camel.processor.loadbalancer.LoadBalancerConsumer v;
v := @this: org.apache.camel.processor.loadbalancer.LoadBalancerConsumer;
v := @parameter: org.apache.camel.Endpoint;
v := @parameter: org.apache.camel.Processor;
v := @parameter: org.apache.camel.processor.loadbalancer.LoadBalancer;
specialinvoke v.<org.apache.camel.impl.DefaultConsumer: void <init>(org.apache.camel.Endpoint,org.apache.camel.Processor)>(v, v);
v.<org.apache.camel.processor.loadbalancer.LoadBalancerConsumer: org.apache.camel.processor.loadbalancer.LoadBalancer loadBalancer> = v;
return;
}
protected void doStart() throws java.lang.Exception
{
org.apache.camel.Processor v;
org.apache.camel.processor.loadbalancer.LoadBalancer v;
org.apache.camel.processor.loadbalancer.LoadBalancerConsumer v;
v := @this: org.apache.camel.processor.loadbalancer.LoadBalancerConsumer;
specialinvoke v.<org.apache.camel.impl.DefaultConsumer: void doStart()>();
v = v.<org.apache.camel.processor.loadbalancer.LoadBalancerConsumer: org.apache.camel.processor.loadbalancer.LoadBalancer loadBalancer>;
v = virtualinvoke v.<org.apache.camel.processor.loadbalancer.LoadBalancerConsumer: org.apache.camel.Processor getProcessor()>();
interfaceinvoke v.<org.apache.camel.processor.loadbalancer.LoadBalancer: void addProcessor(org.apache.camel.Processor)>(v);
return;
}
protected void doStop() throws java.lang.Exception
{
org.apache.camel.Processor v;
org.apache.camel.processor.loadbalancer.LoadBalancer v;
org.apache.camel.processor.loadbalancer.LoadBalancerConsumer v;
v := @this: org.apache.camel.processor.loadbalancer.LoadBalancerConsumer;
v = v.<org.apache.camel.processor.loadbalancer.LoadBalancerConsumer: org.apache.camel.processor.loadbalancer.LoadBalancer loadBalancer>;
v = virtualinvoke v.<org.apache.camel.processor.loadbalancer.LoadBalancerConsumer: org.apache.camel.Processor getProcessor()>();
interfaceinvoke v.<org.apache.camel.processor.loadbalancer.LoadBalancer: void removeProcessor(org.apache.camel.Processor)>(v);
specialinvoke v.<org.apache.camel.impl.DefaultConsumer: void doStop()>();
return;
}
}