Examples of LoadBalancingPolicy

com.datastax.driver.core.policies.LoadBalancingPolicy
The policy that decides which Cassandra hosts to contact for each new query.
Two methods need to be implemented:
- {@link LoadBalancingPolicy#distance}: returns the "distance" of an host for that balancing policy.
- {@link LoadBalancingPolicy#newQueryPlan}: it is used for each query to find which host to query first, and which hosts to use as failover.
The {@code LoadBalancingPolicy} is a {@link com.datastax.driver.core.Host.StateListener}and is thus informed of hosts up/down events. For efficiency purposes, the policy is expected to exclude down hosts from query plans.
com.sun.corba.ee.spi.extension.LoadBalancingPolicy
org.jboss.jms.client.plugin.LoadBalancingPolicy
The interface that must be implemented by any load balancing policy plugin. @author Ovidiu Feodorov @version $Revision: 1981 $ $Id: LoadBalancingPolicy.java 1981 2007-01-18 16:12:55Z clebert.suconic@jboss.com $

Examples of org.jboss.jms.client.plugin.LoadBalancingPolicy

         (ClientConnectionFactoryDelegate[])sortedLocalDelegates.
            toArray(new ClientConnectionFactoryDelegate[sortedLocalDelegates.size()]);


      Map failoverMap = serverPeer.getPostOfficeInstance().getFailoverMap();


      LoadBalancingPolicy lbp = loadBalancingFactory.createLoadBalancingPolicy(delegates);


      endpoint.updateTopology(delegates, failoverMap);


      return new ClientClusteredConnectionFactoryDelegate(uniqueName, delegates, failoverMap, lbp, supportsFailover, enableOrderingGroup, defaultOrderingGroupName);
   }

View Full Code Here

Examples of org.jboss.jms.client.plugin.LoadBalancingPolicy

         (ClientConnectionFactoryDelegate[])sortedLocalDelegates.
            toArray(new ClientConnectionFactoryDelegate[sortedLocalDelegates.size()]);


      Map failoverMap = serverPeer.getPostOfficeInstance().getFailoverMap();


      LoadBalancingPolicy lbp = loadBalancingFactory.createLoadBalancingPolicy(delegates);


      endpoint.updateTopology(delegates, failoverMap);


      return new ClientClusteredConnectionFactoryDelegate(uniqueName, delegates, failoverMap, lbp, supportsFailover, enableOrderingGroup, defaultOrderingGroupName);
   }

View Full Code Here

Examples of org.jboss.jms.client.plugin.LoadBalancingPolicy

         (ClientConnectionFactoryDelegate[])sortedLocalDelegates.
            toArray(new ClientConnectionFactoryDelegate[sortedLocalDelegates.size()]);


      Map failoverMap = serverPeer.getPostOfficeInstance().getFailoverMap();


      LoadBalancingPolicy lbp = loadBalancingFactory.createLoadBalancingPolicy(delegates);


      endpoint.updateTopology(delegates, failoverMap);


      return new ClientClusteredConnectionFactoryDelegate(uniqueName, delegates, failoverMap, lbp, supportsFailover);
   }

View Full Code Here

Examples of org.jboss.jms.client.plugin.LoadBalancingPolicy

                  nextHopingServer = delegate.getServerID();
               }
               else
               {
                 //It's a first time create connection
                  LoadBalancingPolicy loadBalancingPolicy = clusteredDelegate.getLoadBalancingPolicy();                  
                  delegate = (ClientConnectionFactoryDelegate)loadBalancingPolicy.getNext();
               }
            }


            log.trace(this + " has chosen " + delegate + " as target, " +
               (attemptCount == 0 ? "first connection attempt" : attemptCount + " connection attempts"));

View Full Code Here

Examples of org.jboss.jms.client.plugin.LoadBalancingPolicy

                  nextHopingServer = delegate.getServerID();
               }
               else
               {
                 //It's a first time create connection
                  LoadBalancingPolicy loadBalancingPolicy = clusteredDelegate.getLoadBalancingPolicy();                  
                  delegate = (ClientConnectionFactoryDelegate)loadBalancingPolicy.getNext();
               }
            }


            log.trace(this + " has chosen " + delegate + " as target, " +
               (attemptCount == 0 ? "first connection attempt" : attemptCount + " connection attempts"));

View Full Code Here

Examples of org.jboss.jms.client.plugin.LoadBalancingPolicy

         (ClientConnectionFactoryDelegate[])sortedLocalDelegates.
            toArray(new ClientConnectionFactoryDelegate[sortedLocalDelegates.size()]);


      Map failoverMap = serverPeer.getPostOfficeInstance().getFailoverMap();


      LoadBalancingPolicy lbp = loadBalancingFactory.createLoadBalancingPolicy(delegates);


      endpoint.updateTopology(delegates, failoverMap);


      return new ClientClusteredConnectionFactoryDelegate(uniqueName, delegates, failoverMap, lbp, supportsFailover);
   }

View Full Code Here

Examples of org.jboss.jms.client.plugin.LoadBalancingPolicy

         (ClientConnectionFactoryDelegate[])sortedLocalDelegates.
            toArray(new ClientConnectionFactoryDelegate[sortedLocalDelegates.size()]);


      Map failoverMap = serverPeer.getPostOfficeInstance().getFailoverMap();


      LoadBalancingPolicy lbp = loadBalancingFactory.createLoadBalancingPolicy(delegates);


      endpoint.updateTopology(delegates, failoverMap);


      return new ClientClusteredConnectionFactoryDelegate(uniqueName, delegates, failoverMap, lbp, supportsFailover);
   }

View Full Code Here

Examples of org.jboss.jms.client.plugin.LoadBalancingPolicy

                  nextHopingServer = delegate.getServerID();
               }
               else
               {
                 //It's a first time create connection
                  LoadBalancingPolicy loadBalancingPolicy = clusteredDelegate.getLoadBalancingPolicy();                  
                  delegate = (ClientConnectionFactoryDelegate)loadBalancingPolicy.getNext();
               }
            }


            log.trace(this + " has chosen " + delegate + " as target, " +
               (attemptCount == 0 ? "first connection attempt" : attemptCount + " connection attempts"));

View Full Code Here

Examples of org.jboss.jms.client.plugin.LoadBalancingPolicy

         (ClientConnectionFactoryDelegate[])sortedLocalDelegates.
            toArray(new ClientConnectionFactoryDelegate[sortedLocalDelegates.size()]);


      Map failoverMap = serverPeer.getPostOfficeInstance().getFailoverMap();


      LoadBalancingPolicy lbp = loadBalancingFactory.createLoadBalancingPolicy(delegates);


      endpoint.updateTopology(delegates, failoverMap);


      return new ClientClusteredConnectionFactoryDelegate(uniqueName, delegates, failoverMap, lbp, supportsFailover, enableOrderingGroup, defaultOrderingGroupName);
   }

View Full Code Here

Examples of org.jboss.jms.client.plugin.LoadBalancingPolicy

         (ClientConnectionFactoryDelegate[])sortedLocalDelegates.
            toArray(new ClientConnectionFactoryDelegate[sortedLocalDelegates.size()]);


      Map failoverMap = serverPeer.getPostOfficeInstance().getFailoverMap();


      LoadBalancingPolicy lbp = loadBalancingFactory.createLoadBalancingPolicy(delegates);


      endpoint.updateTopology(delegates, failoverMap);


      return new ClientClusteredConnectionFactoryDelegate(uniqueName, delegates, failoverMap, lbp, supportsFailover);
   }

View Full Code Here

0 1 2 3

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.