org.wildfly.clustering.server.dispatcher

Class ChannelCommandDispatcherFactory

java.lang.Object

org.wildfly.clustering.server.dispatcher.ChannelCommandDispatcherFactory

All Implemented Interfaces:

AutoCloseable, org.jgroups.blocks.RequestHandler, org.jgroups.MembershipListener, CommandDispatcherFactory, Group

public class ChannelCommandDispatcherFactory
extends Object
implements CommandDispatcherFactory, org.jgroups.blocks.RequestHandler, AutoCloseable, Group, org.jgroups.MembershipListener

MessageDispatcher based CommandDispatcherFactory. This factory can produce multiple CommandDispatcher instances, all of which will share the same MessageDispatcher instance.

Author:

Paul Ferraro

Nested Class Summary

Nested classes/interfaces inherited from interface org.wildfly.clustering.group.Group

Group.Listener

Constructor Summary

Constructors

Constructor and Description
ChannelCommandDispatcherFactory(ChannelCommandDispatcherFactoryConfiguration config)

Method Summary

Modifier and Type	Method and Description
void	addListener(Group.Listener listener) Registers a membership listener for the group.
void	block()
void	close()
<C> CommandDispatcher<C>	createCommandDispatcher(Object id, C context) Creates a new command dispatcher using the specified identifier and context..
Node	getCoordinatorNode() Returns the group coordinator node.
Group	getGroup() Returns the group upon which the this command dispatcher operates.
Node	getLocalNode() Returns the local node.
String	getName() Returns the name of this group.
List<Node>	getNodes() Returns the list of nodes that are members of this group.
Object	handle(org.jgroups.Message message)
boolean	isCoordinator() Indicates whether or not we are the group coordinator.
void	removeListener(Group.Listener listener) Removes a registered listener from the group.
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

ChannelCommandDispatcherFactory

public ChannelCommandDispatcherFactory(ChannelCommandDispatcherFactoryConfiguration config)

Method Detail

close

public void close()

Specified by:

close in interface AutoCloseable

handle

public Object handle(org.jgroups.Message message)
              throws Exception

Specified by:

handle in interface org.jgroups.blocks.RequestHandler

Throws:

Exception

getGroup

public Group getGroup()

Description copied from interface: CommandDispatcherFactory

Returns the group upon which the this command dispatcher operates.

Specified by:

getGroup in interface CommandDispatcherFactory

Returns:

a group

createCommandDispatcher

public <C> CommandDispatcher<C> createCommandDispatcher(Object id,
                                                        C context)

Description copied from interface: CommandDispatcherFactory

Creates a new command dispatcher using the specified identifier and context.. The resulting CommandDispatcher will communicate with those dispatchers within the group sharing the same identifier.

Specified by:

createCommandDispatcher in interface CommandDispatcherFactory

Parameters:

id - a unique identifier for this dispatcher

context - the context used for executing commands

Returns:

a new command dispatcher

addListener

public void addListener(Group.Listener listener)

Description copied from interface: Group

Registers a membership listener for the group.

Specified by:

addListener in interface Group

Parameters:

listener - listener to be added

removeListener

public void removeListener(Group.Listener listener)

Description copied from interface: Group

Removes a registered listener from the group.

Specified by:

removeListener in interface Group

Parameters:

listener - listener to be removed

getName

public String getName()

Description copied from interface: Group

Returns the name of this group.

Specified by:

getName in interface Group

Returns:

the group name

isCoordinator

public boolean isCoordinator()

Description copied from interface: Group

Indicates whether or not we are the group coordinator.

Specified by:

isCoordinator in interface Group

Returns:

true, if we are the group coordinator, false otherwise

getLocalNode

public Node getLocalNode()

Description copied from interface: Group

Returns the local node.

Specified by:

getLocalNode in interface Group

Returns:

the local node

getCoordinatorNode

public Node getCoordinatorNode()

Description copied from interface: Group

Returns the group coordinator node.

Specified by:

getCoordinatorNode in interface Group

Returns:

the group coordinator node

getNodes

public List<Node> getNodes()

Description copied from interface: Group

Returns the list of nodes that are members of this group.

Specified by:

getNodes in interface Group

Returns:

a list of nodes

viewAccepted

public void viewAccepted(org.jgroups.View view)

Specified by:

viewAccepted in interface org.jgroups.MembershipListener

suspect

public void suspect(org.jgroups.Address member)

Specified by:

suspect in interface org.jgroups.MembershipListener

block

public void block()

Specified by:

block in interface org.jgroups.MembershipListener

unblock

public void unblock()

Specified by:

unblock in interface org.jgroups.MembershipListener