Examples of org.jboss.ha.client.loadbalance.aop.FirstAvailable

Package org.jboss.ha.client.loadbalance.aop

Examples of org.jboss.ha.client.loadbalance.aop.FirstAvailable

org.jboss.ha.client.loadbalance.aop.FirstAvailable
LoadBalancePolicy implementation that, once a target is chosen, always favors that same target; i.e. no further load balancing occurs. Useful in cases where "sticky session" behavior is desired. Differs from the {@link org.jboss.ha.client.loadbalance.FirstAvailable superclass} in the waythat the {@link #chooseTarget(FamilyClusterInfo,Invocation)} method initially selects the target. Instead of always randomly selecting the target, the method will check the passed invocation's metadata for the {@link ClusterConstants#HA_TARGET} key in the {@link ClusterConstants#CLUSTERED_REMOTING} group. If an object is found there and it is a valid target associated with the given FamilyClusterInfo, that target will be used. Otherwise the target will be randomly chosen. This mechanism allows the proxy that contains this policy to specify the preferred target via invocation metadata.
Each proxy using this policy will choose its own preferred target: the target is not shared accross the proxy family. For shared behaviour please take a look at {@link FirstAvailableIdenticalAllProxies}.
@author Brian Stansberry @version $Revision: 57642 $

      ClusteringTargetsRepository.initTarget(proxyFamilyName, hatarget.getReplicants());
      container.getClusterFamilies().put(proxyFamilyName, hatarget);
      
      if (clustered.loadBalancePolicy() == null || clustered.loadBalancePolicy().equals(ClusteredDefaults.LOAD_BALANCE_POLICY_DEFAULT))
      {
         lbPolicy = new FirstAvailable();
      }
      else
      {
         String policyClass = clustered.loadBalancePolicy();
         try

View Full Code Here

      ClusteringTargetsRepository.initTarget(proxyFamilyName, hatarget.getReplicants());
      container.getClusterFamilies().put(proxyFamilyName, hatarget);
      
      if (clustered.loadBalancePolicy() == null || clustered.loadBalancePolicy().equals(ClusteredDefaults.LOAD_BALANCE_POLICY_DEFAULT))
      {
         lbPolicy = new FirstAvailable();
      }
      else
      {
         String policyClass = clustered.loadBalancePolicy();
         try

View Full Code Here

      super(name);
   }
   
   protected LoadBalancePolicy getLoadBalancePolicy()
   {
      return new FirstAvailable();
   }

View Full Code Here

      super(name);
   }
   
   protected FirstAvailable getLoadBalancePolicy()
   {
      return new FirstAvailable();
   }

View Full Code Here

      ClusteringTargetsRepository.initTarget(proxyFamilyName, hatarget.getReplicants());
      container.getClusterFamilies().put(proxyFamilyName, hatarget);
      
      if (clustered.loadBalancePolicy() == null || clustered.loadBalancePolicy().equals(ClusteredDefaults.LOAD_BALANCE_POLICY_DEFAULT))
      {
         lbPolicy = new FirstAvailable();
      }
      else
      {
         String policyClass = clustered.loadBalancePolicy();
         try

View Full Code Here

      ClusteringTargetsRepository.initTarget(proxyFamilyName, hatarget.getReplicants());
      container.getClusterFamilies().put(proxyFamilyName, hatarget);
      
      if (clustered.loadBalancePolicy() == null || clustered.loadBalancePolicy().equals(ClusteredDefaults.LOAD_BALANCE_POLICY_DEFAULT))
      {
         lbPolicy = new FirstAvailable();
      }
      else
      {
         String policyClass = clustered.loadBalancePolicy();
         try

View Full Code Here

      ClusteringTargetsRepository.initTarget(proxyFamilyName, hatarget.getReplicants());
      container.getClusterFamilies().put(proxyFamilyName, hatarget);
      
      if (clustered.loadBalancePolicy() == null || clustered.loadBalancePolicy().equals(ClusteredDefaults.LOAD_BALANCE_POLICY_DEFAULT))
      {
         lbPolicy = new FirstAvailable();
      }
      else
      {
         String policyClass = clustered.loadBalancePolicy();
         try

View Full Code Here

TOP

Related Classes of org.jboss.ha.client.loadbalance.aop.FirstAvailable

org.jboss.ejb3.proxy.factory.stateful.StatefulClusterProxyFactory

org.jboss.test.ha.client.loadbalance.aop.FirstAvailableUnitTestCase

java.util.List

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.