Package com.gigaspaces.cluster.activeelection.core

Class ActiveElectionManager

java.lang.Object
com.gigaspaces.cluster.activeelection.core.ActiveElectionManager
public class ActiveElectionManager extends Object
ActiveElectionManager based on distributed naming service INamingService and provides a distributed active election algorithm to select only one active service between all candidates.

NOTE: The manage service must provide consistent equals() method implementation or implement ReferentUuid interface. Example: 

   
    public class ServiceIDOrderFilter
      implements IActiveElectionDecisionFilter
    {
         ServiceID _srvID;

     public boolean isAcceptable(ActiveElectionState.State advanceState, List
 candidateSrv )
     {
       for( ServiceItem srvItem : candidateSrv )
       {
        // return true if _srvID is the greater from all candidateSrv.serviceID;
       }
     }
    }

    public class ElectionListener
                implements IActiveElectionListener
    {
      ActiveElectionManager _electManager;

      public void onActive( ActiveElectionEvent event )
      {
        System.out.println("OnActive -> Elected Active: " + event.getActiveServiceItem() );

        if ( _electManager.getState() == ActiveElectionState.State.ACTIVE )
          System.out.println("The manage service is an ACTIVE");
        else
          System.out.println("The manage service is an NOT an ACTIVE");

       }

       public void onSplitBrain( ActiveElectionEvent event )
       {
         System.out.println("OnSplit -> Elected Active: " + event.getActiveServiceItem() ); *
       }
     }

    public static void main( String[] args )
    {
     IJSpace space;
     ServiceTemplate srvTemplate;
     INamingService lookupSrv    = new LookupNamingService();
     ElectionListener listener   = new ElectionListener();
     ServiceIDOrderFilter filter = new ServiceIDOrderFilter();

     ActiveElectionManager electManager = new ActiveElectionManager( space, srvTemplate,
 lookupSrv, listener, filter );
     electManager.elect();
    }
Since:
6.0
Version:
1.0
Author:
Igor Goldenberg
See Also: