public void notify(final QuorumEvent e){
  if (log.isInfoEnabled())   log.info(e.toString());
switch (e.getEventType()) {
case MEMBER_ADD:
{
      memberAdd(e.getServiceId());
      break;
    }
case MEMBER_REMOVE:
{
    memberRemove(e.getServiceId());
    break;
  }
case PIPELINE_ADD:
{
  pipelineAdd(e.getServiceId());
  break;
}
case PIPELINE_REMOVE:
{
pipelineRemove(e.getServiceId());
break;
}
case CAST_VOTE:
{
castVote(e.getServiceId(),e.lastCommitTime());
break;
}
case WITHDRAW_VOTE:
{
withdrawVote(e.getServiceId());
break;
}
case SERVICE_JOIN:
{
serviceJoin(e.getServiceId());
break;
}
case SERVICE_LEAVE:
{
serviceLeave(e.getServiceId());
break;
}
case QUORUM_MEET:
{
setToken(e.lastValidToken());
break;
}
case QUORUM_BROKE:
{
clearToken();
break;
}
default :
log.warn("Ignoring : " + e);
}
}

public void notify ( final QuorumEvent e ) { if ( log . isInfoEnabled ( ) ) log . info ( e . toString ( ) ) ; switch ( e . getEventType ( ) ) { case MEMBER_ADD : { memberAdd ( e . getServiceId ( ) ) ; break ; } case MEMBER_REMOVE : { memberRemove ( e . getServiceId ( ) ) ; break ; } case PIPELINE_ADD : { pipelineAdd ( e . getServiceId ( ) ) ; break ; } case PIPELINE_REMOVE : { pipelineRemove ( e . getServiceId ( ) ) ; break ; } case CAST_VOTE : { castVote ( e . getServiceId ( ) , e . lastCommitTime ( ) ) ; break ; } case WITHDRAW_VOTE : { withdrawVote ( e . getServiceId ( ) ) ; break ; } case SERVICE_JOIN : { serviceJoin ( e . getServiceId ( ) ) ; break ; } case SERVICE_LEAVE : { serviceLeave ( e . getServiceId ( ) ) ; break ; } case QUORUM_MEET : { setToken ( e . lastValidToken ( ) ) ; break ; } case QUORUM_BROKE : { clearToken ( ) ; break ; } default : log . warn ( "Ignoring : " + e ) ; } }
propagate state change to our quorum .
