org.wildfly.clustering.server.dispatcher

Class ChannelCommandDispatcher<C>

java.lang.Object

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

Type Parameters:

C - command execution context

All Implemented Interfaces:

AutoCloseable, CommandDispatcher<C>

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

MessageDispatcher-based command dispatcher.

Author:

Paul Ferraro

Constructor Summary

Constructors

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

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

ChannelCommandDispatcher

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

Method Detail

executeOnCluster

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

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

Throws:

Exception - if the command could not be broadcast

submitOnCluster

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

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.

Throws:

Exception - if the command could not be broadcast

executeOnNode

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

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

Throws:

Exception - if the command could not be sent

submitOnNode

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

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

Throws:

Exception - if the command could not be sent