Constructor Detail

• SimpleCoordinator

  public SimpleCoordinator()

Method Detail

• memberAdded

  public void memberAdded(Member member)

  Description copied from interface: MembershipListener
  A member was added to the group

  Specified by:

  memberAdded in interface MembershipListener

  Overrides:

  memberAdded in class ChannelInterceptorBase

  Parameters:

  member - Member - the member that was added

• memberDisappeared

  public void memberDisappeared(Member member)

  Description copied from interface: MembershipListener
  A member was removed from the group
  If the member left voluntarily, the Member.getCommand will contain the Member.SHUTDOWN_PAYLOAD data

  Specified by:

  memberDisappeared in interface MembershipListener

  Overrides:

  memberDisappeared in class ChannelInterceptorBase

  Parameters:

  member - Member

  See Also:

  Member.SHUTDOWN_PAYLOAD

• viewChange

  protected void viewChange(Member[] view)

  Override to receive view changes.

  Parameters:

  view -

• start

  public void start(int svc)
             throws ChannelException

  Description copied from class: ChannelInterceptorBase
  Starts up the channel. This can be called multiple times for individual services to start The svc parameter can be the logical or value of any constants

  Specified by:

  start in interface ChannelInterceptor

  Overrides:

  start in class ChannelInterceptorBase

  Parameters:

  svc - int value of
  DEFAULT - will start all services
  MBR_RX_SEQ - starts the membership receiver
  MBR_TX_SEQ - starts the membership broadcaster
  SND_TX_SEQ - starts the replication transmitter
  SND_RX_SEQ - starts the replication receiver
  

  Throws:

  ChannelException - if a startup error occurs or the service is already started.

  See Also:

  Channel

• stop

  public void stop(int svc)
            throws ChannelException

  Description copied from class: ChannelInterceptorBase
  Shuts down the channel. This can be called multiple times for individual services to shutdown The svc parameter can be the logical or value of any constants

  Specified by:

  stop in interface ChannelInterceptor

  Overrides:

  stop in class ChannelInterceptorBase

  Parameters:

  svc - int value of
  DEFAULT - will shutdown all services
  MBR_RX_SEQ - stops the membership receiver
  MBR_TX_SEQ - stops the membership broadcaster
  SND_TX_SEQ - stops the replication transmitter
  SND_RX_SEQ - stops the replication receiver
  

  Throws:

  ChannelException - if a startup error occurs or the service is already started.

  See Also:

  Channel

• getView

  public Member[] getView()

• getCoordinator

  public Member getCoordinator()

• isCoordinator

  public boolean isCoordinator()