org.wildfly.clustering.server.dispatcher

Class ServiceCommandDispatcher<C>

java.lang.Object

org.wildfly.clustering.server.dispatcher.ServiceCommandDispatcher<C>

Type Parameters:

C - command execution context

All Implemented Interfaces:

AutoCloseable, CommandDispatcher<C>

public abstract class ServiceCommandDispatcher<C>
extends Object
implements CommandDispatcher<C>

MessageDispatcher-based command dispatcher.

Author:

Paul Ferraro

Constructor Summary

Constructors

Constructor and Description
ServiceCommandDispatcher(org.jgroups.blocks.MessageDispatcher dispatcher, CommandMarshaller<C> marshaller, NodeFactory<org.jgroups.Address> factory, long timeout)

Method Summary

Modifier and Type	Method and Description
<R> Map<Node,CommandResponse<R>>	executeOnCluster(Command<R,C> command, Node... excludedNodes) Execute the specified command on all nodes in the group, excluding the specified nodes
<R> CommandResponse<R>	executeOnNode(Command<R,C> command, Node node) Execute the specified command on the specified node.
<R> Map<Node,Future<R>>	submitOnCluster(Command<R,C> command, Node... excludedNodes) Submits the specified command on all nodes in the group, excluding the specified nodes.
<R> Future<R>	submitOnNode(Command<R,C> command, Node node) Submits the specified command on the specified node for execution.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.wildfly.clustering.dispatcher.CommandDispatcher

close

Constructor Detail

ServiceCommandDispatcher

public ServiceCommandDispatcher(org.jgroups.blocks.MessageDispatcher dispatcher,
                                CommandMarshaller<C> marshaller,
                                NodeFactory<org.jgroups.Address> factory,
                                long timeout)

Method Detail

executeOnCluster

public <R> Map<Node,CommandResponse<R>> executeOnCluster(Command<R,C> command,
                                                         Node... excludedNodes)

Description copied from interface: CommandDispatcher

Execute the specified command on all nodes in the group, excluding the specified nodes

Specified by:

executeOnCluster in interface CommandDispatcher<C>

Type Parameters:

R - the return value type

Parameters:

command - the command to execute

excludedNodes - the set of nodes to exclude

Returns:

a map of command execution results per node

submitOnCluster

public <R> Map<Node,Future<R>> submitOnCluster(Command<R,C> command,
                                               Node... excludedNodes)

Description copied from interface: CommandDispatcher

Submits the specified command on all nodes in the group, excluding the specified nodes.

Specified by:

submitOnCluster in interface CommandDispatcher<C>

Type Parameters:

R - the return value type

Parameters:

command - the command to execute

excludedNodes - the set of nodes to exclude

Returns:

a map of command execution results per node.

executeOnNode

public <R> CommandResponse<R> executeOnNode(Command<R,C> command,
                                            Node node)

Description copied from interface: CommandDispatcher

Execute the specified command on the specified node.

Specified by:

executeOnNode in interface CommandDispatcher<C>

Type Parameters:

R - the return value type

Parameters:

command - the command to execute

node - the node to execute the command on

Returns:

the result of the command execution

submitOnNode

public <R> Future<R> submitOnNode(Command<R,C> command,
                                  Node node)

Description copied from interface: CommandDispatcher

Submits the specified command on the specified node for execution.

Specified by:

submitOnNode in interface CommandDispatcher<C>

Type Parameters:

R - the return value type

Parameters:

command - the command to execute

node - the node to execute the command on

Returns:

the result of the command execution