C
- the command context typepublic interface CommandDispatcher<C> extends AutoCloseable
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes any resources used by this dispatcher.
|
<R> Map<Node,CommandResponse<R>> |
executeOnCluster(Command<R,? super C> command,
Node... excludedNodes)
Execute the specified command on all nodes in the group, excluding the specified nodes
|
<R> CommandResponse<R> |
executeOnNode(Command<R,? super C> command,
Node node)
Execute the specified command on the specified node.
|
<R> Map<Node,Future<R>> |
submitOnCluster(Command<R,? super C> command,
Node... excludedNodes)
Submits the specified command on all nodes in the group, excluding the specified nodes.
|
<R> Future<R> |
submitOnNode(Command<R,? super C> command,
Node node)
Submits the specified command on the specified node for execution.
|
<R> CommandResponse<R> executeOnNode(Command<R,? super C> command, Node node) throws CommandDispatcherException
R
- the return value typecommand
- the command to executenode
- the node to execute the command onCommandDispatcherException
- if the command could not be sent<R> Map<Node,CommandResponse<R>> executeOnCluster(Command<R,? super C> command, Node... excludedNodes) throws CommandDispatcherException
R
- the return value typecommand
- the command to executeexcludedNodes
- the set of nodes to excludeCommandDispatcherException
- if the command could not be broadcast<R> Future<R> submitOnNode(Command<R,? super C> command, Node node) throws CommandDispatcherException
R
- the return value typecommand
- the command to executenode
- the node to execute the command onCommandDispatcherException
- if the command could not be sent<R> Map<Node,Future<R>> submitOnCluster(Command<R,? super C> command, Node... excludedNodes) throws CommandDispatcherException
R
- the return value typecommand
- the command to executeexcludedNodes
- the set of nodes to excludeCommandDispatcherException
- if the command could not be broadcastvoid close()
close
in interface AutoCloseable
Copyright © 2017 JBoss by Red Hat. All rights reserved.