Examples of LoadBalancer

com.cloud.network.rules.LoadBalancer
Definition for a LoadBalancer
com.hazelcast.client.LoadBalancer
{@link LoadBalancer} allows you to send operations to one of a number of endpoints(Members).It is up to the implementation to use different load balancing policies.
If Client is configured with {@link com.hazelcast.client.config.ClientConfig#isSmartRouting()}, only the operations that are not key based will be router to the endpoint returned by the LoadBalancer. If it is not {@link com.hazelcast.client.config.ClientConfig#isSmartRouting()}, {@link LoadBalancer} will not be used.
com.microsoft.windowsazure.management.compute.models.LoadBalancer
A list of internal load balancers that each provide load balancing on a private VIP.
com.sun.appserv.management.ext.lb.LoadBalancer
Runtime counterpart for the config MBean {@link com.sun.appserv.management.config.LoadBalancerConfig} representing the load-balancer element.
com.sun.enterprise.config.serverbeans.LoadBalancer
com.sun.enterprise.ee.admin.lbadmin.beans.Loadbalancer
io.fabric8.gateway.loadbalancer.LoadBalancer
Represents the load balancing algorithm to use to pick which service to use. Example implementations are: {@link RandomLoadBalancer}, {@link RoundRobinLoadBalancer} or {@link StickyLoadBalancer}
org.apache.camel.processor.loadbalancer.LoadBalancer
A strategy for load balancing across a number of {@link Processor} instances @version $Revision: 1.1 $
org.apache.hadoop.hbase.master.LoadBalancer
Makes decisions about the placement and movement of Regions across RegionServers.
Cluster-wide load balancing will occur only when there are no regions in transition and according to a fixed period of a time using {@link #balanceCluster(Map)}.
Inline region placement with {@link #immediateAssignment} can be used whenthe Master needs to handle closed regions that it currently does not have a destination set for. This can happen during master failover.
On cluster startup, bulk assignment can be used to determine locations for all Regions in a cluster.
This classes produces plans for the {@link AssignmentManager} to execute.
org.glassfish.loadbalancer.admin.cli.beans.Loadbalancer
org.glassfish.loadbalancer.config.LoadBalancer
org.jclouds.elb.domain.LoadBalancer
nwebservices.com/ElasticLoadBalancing/latest/DeveloperGuide/arch-loadbalancing.html" >doc @author Adrian Cole
org.jclouds.gogrid.domain.LoadBalancer
Class LoadBalancer @author Oleksiy Yarmula
org.jclouds.rackspace.cloudloadbalancers.v1.domain.LoadBalancer
@author Adrian Cole
org.jvnet.glassfish.comms.clb.admin.Loadbalancer

Examples of org.apache.camel.processor.loadbalancer.LoadBalancer

    }


    protected Processor createOutputsProcessor(RouteContext routeContext,
        Collection<ProcessorDefinition<?>> outputs) throws Exception {


        LoadBalancer loadBalancer = LoadBalancerDefinition.getLoadBalancer(routeContext, loadBalancerType, ref);
        for (ProcessorDefinition<?> processorType : outputs) {
            Processor processor = createProcessor(routeContext, processorType);
            loadBalancer.addProcessor(processor);
        }
        return loadBalancer;
    }

View Full Code Here

Examples of org.apache.camel.processor.loadbalancer.LoadBalancer

        return loadBalancer;
    }
    
    @Override
    public Processor createProcessor(RouteContext routeContext) throws Exception {
        LoadBalancer loadBalancer = LoadBalancerDefinition.getLoadBalancer(routeContext, loadBalancerType, ref);
        for (ProcessorDefinition<?> processorType : getOutputs()) {
            // output must not be another load balancer
            // check for instanceof as the code below as there is compilation errors on earlier versions of JDK6
            // on Windows boxes or with IBM JDKs etc.
            if (LoadBalanceDefinition.class.isInstance(processorType)) {
                throw new IllegalArgumentException("Loadbalancer already configured to: " + loadBalancerType + ". Cannot set it to: " + processorType);
            }
            Processor processor = createProcessor(routeContext, processorType);
            processor = wrapChannel(routeContext, processor, processorType);
            loadBalancer.addProcessor(processor);
        }
        return loadBalancer;
    }

View Full Code Here

Examples of org.apache.camel.processor.loadbalancer.LoadBalancer

        loadBalancerType = loadbalancer;
    }


    protected Processor createOutputsProcessor(RouteContext routeContext, Collection<ProcessorType<?>> outputs)
        throws Exception {
        LoadBalancer loadBalancer = LoadBalancerType.getLoadBalancer(routeContext, loadBalancerType, ref);
        for (ProcessorType processorType : outputs) {
            // The outputs should be the SendProcessor
            SendProcessor processor = (SendProcessor) processorType.createProcessor(routeContext);
            loadBalancer.addProcessor(processor);
        }
        return loadBalancer;
    }

View Full Code Here

Examples of org.apache.camel.processor.loadbalancer.LoadBalancer

        return loadBalancer;
    }
    
    @Override
    public Processor createProcessor(RouteContext routeContext) throws Exception {
        LoadBalancer loadBalancer = LoadBalancerType.getLoadBalancer(routeContext, loadBalancerType, ref);
        for (ProcessorType processorType : getOutputs()) {            
            Processor processor = processorType.createProcessor(routeContext);
            processor = processorType.wrapProcessorInInterceptors(routeContext, processor);
            loadBalancer.addProcessor(processor);
        }


        return loadBalancer;
    }

View Full Code Here

Examples of org.apache.camel.processor.loadbalancer.LoadBalancer

        loadBalancerType = loadbalancer;
    }


    protected Processor createOutputsProcessor(RouteContext routeContext, Collection<ProcessorType<?>> outputs)
        throws Exception {
        LoadBalancer loadBalancer = LoadBalancerType.getLoadBalancer(routeContext, loadBalancerType, ref);
        for (ProcessorType processorType : outputs) {
            // The outputs should be the SendProcessor
            SendProcessor processor = (SendProcessor) processorType.createProcessor(routeContext);
            loadBalancer.addProcessor(processor);
        }
        return loadBalancer;
    }

View Full Code Here

Examples of org.apache.camel.processor.loadbalancer.LoadBalancer

        return loadBalancer;
    }
    
    @Override
    public Processor createProcessor(RouteContext routeContext) throws Exception {
        LoadBalancer loadBalancer = LoadBalancerType.getLoadBalancer(routeContext, loadBalancerType, ref);
        for (ProcessorType processorType : getOutputs()) {            
            Processor processor = processorType.createProcessor(routeContext);
            processor = processorType.wrapProcessorInInterceptors(routeContext, processor);
            loadBalancer.addProcessor(processor);
        }


        return loadBalancer;
    }

View Full Code Here

Examples of org.apache.camel.processor.loadbalancer.LoadBalancer

        loadBalancerType = loadbalancer;
    }


    protected Processor createOutputsProcessor(RouteContext routeContext,
                                               Collection<ProcessorDefinition> outputs) throws Exception {
        LoadBalancer loadBalancer = LoadBalancerDefinition.getLoadBalancer(routeContext, loadBalancerType, ref);
        for (ProcessorDefinition<?> processorType : outputs) {
            Processor processor = processorType.createProcessor(routeContext);
            loadBalancer.addProcessor(processor);
        }
        return loadBalancer;
    }

View Full Code Here

Examples of org.apache.camel.processor.loadbalancer.LoadBalancer

        return loadBalancer;
    }
    
    @Override
    public Processor createProcessor(RouteContext routeContext) throws Exception {
        LoadBalancer loadBalancer = LoadBalancerDefinition.getLoadBalancer(routeContext, loadBalancerType, ref);
        for (ProcessorDefinition<?> processorType : getOutputs()) {
            // output must not be another load balancer
            // check for instanceof as the code below as there is compilation errors on earlier versions of JDK6
            // on Windows boxes or with IBM JDKs etc.
            if (LoadBalanceDefinition.class.isInstance(processorType)) {
                throw new IllegalArgumentException("Loadbalancer already configured to: " + loadBalancerType + ". Cannot set it to: " + processorType);
            }
            Processor processor = processorType.createProcessor(routeContext);
            processor = wrapChannel(routeContext, processor, processorType);
            loadBalancer.addProcessor(processor);
        }
        return loadBalancer;
    }

View Full Code Here

Examples of org.apache.camel.processor.loadbalancer.LoadBalancer

    }


    public static LoadBalancer getLoadBalancer(RouteContext routeContext, LoadBalancerDefinition type, String ref) {
        if (type == null) {
            ObjectHelper.notNull(ref, "ref or loadBalancer");
            LoadBalancer loadBalancer = routeContext.mandatoryLookup(ref, LoadBalancer.class);
            if (loadBalancer instanceof LoadBalancerDefinition) {
                type = (LoadBalancerDefinition) loadBalancer;
            } else {
                return loadBalancer;
            }

View Full Code Here

Examples of org.apache.camel.processor.loadbalancer.LoadBalancer

     *
     * @param jobExecutionContext the Quartz Job context
     */
    public void onJobExecute(final JobExecutionContext jobExecutionContext) throws JobExecutionException {
        boolean run = true;
        LoadBalancer balancer = getLoadBalancer();
        if (balancer instanceof ServiceSupport) {
            run = ((ServiceSupport) balancer).isRunAllowed();
        }


        if (!run) {
            // quartz scheduler could potential trigger during a route has been shutdown
            LOG.warn("Cannot execute Quartz Job with context: " + jobExecutionContext + " because processor is not started: " + balancer);
            return;
        }


        LOG.debug("Firing Quartz Job with context: {}", jobExecutionContext);
        Exchange exchange = createExchange(jobExecutionContext);
        try {
            balancer.process(exchange);


            if (exchange.getException() != null) {
                // propagate the exception back to Quartz
                throw new JobExecutionException(exchange.getException());
            }

View Full Code Here

0 1 2 3 4 5 6

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.