org.zeromq.jzmq.bstar

Class BinaryStarReactorImpl

java.lang.Object

org.zeromq.jzmq.bstar.BinaryStarReactorImpl

All Implemented Interfaces:

BinaryStarReactor

public class BinaryStarReactorImpl
extends Object
implements BinaryStarReactor

Nested Class Summary

Nested classes/interfaces inherited from interface org.zeromq.api.BinaryStarReactor

BinaryStarReactor.Event, BinaryStarReactor.Mode, BinaryStarReactor.State

Field Summary

Fields inherited from interface org.zeromq.api.BinaryStarReactor

BSTAR_HEARTBEAT

Constructor Summary

Constructors

Constructor and Description
BinaryStarReactorImpl(ManagedContext context, BinaryStarReactor.Mode mode, String local, String remote) This is the constructor for our BinaryStarReactorImpl class.

Method Summary

Modifier and Type	Method and Description
Reactor	getReactor() This method returns the underlying Reactor, so we can add additional timers and readers.
void	registerVoterSocket(Socket socket) This method registers a client voter socket.
void	setActiveHandler(LoopHandler handler) Register handlers to be called each time there's a state change.
void	setHeartbeatInterval(long heartbeatInterval) Set the heartbeat interval used to detect peer outage.
void	setPassiveHandler(LoopHandler handler) Register handlers to be called each time there's a state change.
void	setVoterHandler(LoopHandler handler) Register handlers to be called each time there's a state change.
void	start() Start the configured reactor.
void	stop() Stop the reactor.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BinaryStarReactorImpl

public BinaryStarReactorImpl(ManagedContext context,
                             BinaryStarReactor.Mode mode,
                             String local,
                             String remote)

This is the constructor for our BinaryStarReactorImpl class. We have to tell it whether we're primary or backup server, as well as our local and remote endpoints to bind and connect to.

Parameters:

context - The ManagedContext

mode - The connection mode, either primary or backup

local - The local socket endpoint for publishing events

remote - The remote socket endpoint for subscribing to events

Method Detail

start

public void start()

Start the configured reactor.

Specified by:

start in interface BinaryStarReactor

stop

public void stop()

Stop the reactor.

Specified by:

stop in interface BinaryStarReactor

registerVoterSocket

public void registerVoterSocket(Socket socket)

This method registers a client voter socket. Messages received on this socket provide the CLIENT_REQUEST events for the Binary Star FSM and are passed to the provided application handler. We require exactly one voter per BinaryStarReactorImpl instance.

Specified by:

registerVoterSocket in interface BinaryStarReactor

Parameters:

socket - The client socket

setVoterHandler

public void setVoterHandler(LoopHandler handler)

Register handlers to be called each time there's a state change.

Specified by:

setVoterHandler in interface BinaryStarReactor

Parameters:

handler - The handler for client events

setActiveHandler

public void setActiveHandler(LoopHandler handler)

Register handlers to be called each time there's a state change.

Specified by:

setActiveHandler in interface BinaryStarReactor

Parameters:

handler - The handler for state change events

setPassiveHandler

public void setPassiveHandler(LoopHandler handler)

Register handlers to be called each time there's a state change.

Specified by:

setPassiveHandler in interface BinaryStarReactor

Parameters:

handler - The handler for state change events

getReactor

public Reactor getReactor()

This method returns the underlying Reactor, so we can add additional timers and readers.

Specified by:

getReactor in interface BinaryStarReactor

Returns:

The underlying Reactor

setHeartbeatInterval

public void setHeartbeatInterval(long heartbeatInterval)

Set the heartbeat interval used to detect peer outage.

Specified by:

setHeartbeatInterval in interface BinaryStarReactor

Parameters:

heartbeatInterval - The heartbeat interval, in milliseconds