net.sf.hajdbc.distributed.jgroups

Class JGroupsCommandDispatcher<C>

java.lang.Object

net.sf.hajdbc.distributed.jgroups.JGroupsCommandDispatcher<C>

Type Parameters:

C - the execution context type

All Implemented Interfaces:

CommandDispatcher<C>, Lifecycle, org.jgroups.blocks.RequestHandler, org.jgroups.MembershipListener, org.jgroups.MessageListener

public class JGroupsCommandDispatcher<C>
extends Object
implements org.jgroups.blocks.RequestHandler, CommandDispatcher<C>, org.jgroups.MembershipListener, org.jgroups.MessageListener

A JGroups-based command dispatcher.

Author:

Paul Ferraro

See Also:

MessageDispatcher

Constructor Summary

Constructors

Constructor and Description
JGroupsCommandDispatcher(String id, org.jgroups.Channel channel, long timeout, C context, Stateful stateful, MembershipListener membershipListener) Constructs a new ChannelCommandDispatcher.

Method Summary

Methods

Modifier and Type	Method and Description
void	block()
<R> R	execute(Command<R,C> command, Member member) Execute the specified command on the specified member.
<R> Map<Member,R>	executeAll(Command<R,C> command, Member... excludedMembers) Execute the specified command on all members, potentially excluding some.
AddressMember	getCoordinator() Returns the group coordinator.
AddressMember	getLocal() Returns the local member.
void	getState(OutputStream output)
Object	handle(org.jgroups.Message message)
void	receive(org.jgroups.Message message)
void	setState(InputStream input)
void	start() Called upon database cluster start.
void	stop() Called when database cluster is stopped.
void	suspect(org.jgroups.Address member)
void	unblock()
void	viewAccepted(org.jgroups.View view)

Methods inherited from class java.lang.Object

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

Constructor Detail

JGroupsCommandDispatcher

public JGroupsCommandDispatcher(String id,
                        org.jgroups.Channel channel,
                        long timeout,
                        C context,
                        Stateful stateful,
                        MembershipListener membershipListener)
                         throws Exception

Constructs a new ChannelCommandDispatcher.

Parameters:

id - the channel name

channel - a JGroups channel

timeout - the command timeout

context - the execution context

stateful - the state transfer handler

membershipListener - notified of membership changes

Throws:

Exception - if channel cannot be created

Method Detail

start

public void start()
           throws Exception

Called upon database cluster start.

Specified by:

start in interface Lifecycle

Throws:

Exception - if this service fails to start.

See Also:

Lifecycle.start()

stop

public void stop()

Called when database cluster is stopped.

Specified by:

stop in interface Lifecycle

See Also:

Lifecycle.stop()

executeAll

public <R> Map<Member,R> executeAll(Command<R,C> command,
                           Member... excludedMembers)

Description copied from interface: CommandDispatcher

Execute the specified command on all members, potentially excluding some.

Specified by:

executeAll in interface CommandDispatcher<C>

Type Parameters:

R - the return value type

Parameters:

command - the command to execute

excludedMembers - list of members to optionally exclude

Returns:

a map of command execution results per member.

execute

public <R> R execute(Command<R,C> command,
            Member member)

Execute the specified command on the specified member.

Specified by:

execute in interface CommandDispatcher<C>

Type Parameters:

R - the return value type

Parameters:

command - the command to execute

member - the member on which to execute the command

Returns:

the result of the command execution

See Also:

net.sf.hajdbc.distributed.CommandDispatcher#executeCoordinator(net.sf.hajdbc.distributed.Command)

getLocal

public AddressMember getLocal()

Returns the local member.

Specified by:

getLocal in interface CommandDispatcher<C>

Returns:

the local member.

See Also:

CommandDispatcher.getLocal()

getCoordinator

public AddressMember getCoordinator()

Returns the group coordinator.

Specified by:

getCoordinator in interface CommandDispatcher<C>

Returns:

the group coordinator.

See Also:

CommandDispatcher.getCoordinator()

handle

public Object handle(org.jgroups.Message message)

Specified by:

handle in interface org.jgroups.blocks.RequestHandler

See Also:

RequestHandler.handle(org.jgroups.Message)

viewAccepted

public void viewAccepted(org.jgroups.View view)

Specified by:

viewAccepted in interface org.jgroups.MembershipListener

See Also:

MembershipListener.viewAccepted(org.jgroups.View)

getState

public void getState(OutputStream output)
              throws Exception

Specified by:

getState in interface org.jgroups.MessageListener

Throws:

Exception

See Also:

MessageListener.getState(java.io.OutputStream)

setState

public void setState(InputStream input)
              throws Exception

Specified by:

setState in interface org.jgroups.MessageListener

Throws:

Exception

See Also:

MessageListener.setState(java.io.InputStream)

suspect

public void suspect(org.jgroups.Address member)

Specified by:

suspect in interface org.jgroups.MembershipListener

See Also:

MembershipListener.suspect(org.jgroups.Address)

block

public void block()

Specified by:

block in interface org.jgroups.MembershipListener

See Also:

MembershipListener.block()

unblock

public void unblock()

Specified by:

unblock in interface org.jgroups.MembershipListener

See Also:

MembershipListener.unblock()

receive

public void receive(org.jgroups.Message message)

Specified by:

receive in interface org.jgroups.MessageListener

See Also:

MessageListener.receive(org.jgroups.Message)