Routers
Use routers to offload command and event dispatching toward an eventual outcome.
Message-driven command routing to handlers offloads the responsibility of dispatching potential effects to the domain model. When using CQRS the model is known as the Command Model or Write Model.
The following shows a fully asynchronous/concurrent command routing component available with XOOM Lattice.
See the package
io.vlingo.xoom.lattice.router:Type
Description
CommandRouterThe interface protocol for command routers. Provides a static factory method to create any of three types of routers:
LoadBalancingCommandRouterPartitioningCommandRouterRoundRobinCommandRouter
All concrete
CommandRouter types must implement this protocol: void route(final RoutableCommand command)CommandDispatcher<P, C extends Command, A> All commands routed through a
CommandRouter must implement the CommandDispatcher interface. The P is the type name of the protocol to which the command will be sent. The C is the type name of this command type, which must be a subclass of io.vlingo.xoom.lattice.model.Command. The A is the answer type to be provided by the command, and is normally a Completes<T> where T is the type to be answered asynchronously.RoutableCommandA command to be routed through a defined
CommandRouter. This is a standard container for a concrete command type. In other words, create a command type, such as Rename, that implements the protocol CommandDispatcher and instantiate a new RoutableCommand with the Rename command inside. The RoutableCommand is sent through the CommandRouter and the Rename command internally knows how to send a message to its P generic protocol type parameter.The next section explains how to use these types and components.
Commands and Dispatching
You can see examples of this use in the XOOM Schemata implementation source code. The following demonstrates how a single command set is defined and used by Schemata.
Instantiating the Command
This examines the XOOM Schemata command set that support schema definitions. Since the command types are somewhat redundant other than the parameter details, the entire source is not shown.
As a design choice, all commands for a given feature are defined inside an outer parent class. In the case of schema definition commands, the parent class is
SchemaCommands. Inside SchemaCommands where are a number of concrete command types. The SchemaCommands is a factory that instantiates all the concrete command types as needed. See the main source for full details, such as all necessary imports, etc.1
package io.vlingo.xoom.schemata.resource;
2
​
3
import io.vlingo.xoom.common.Completes;
4
import io.vlingo.xoom.lattice.model.Command;
5
import io.vlingo.xoom.lattice.router.CommandDispatcher;
6
import io.vlingo.xoom.lattice.router.CommandRouter;
7
import io.vlingo.xoom.lattice.router.CommandRouter.Type;
8
import io.vlingo.xoom.lattice.router.RoutableCommand;
9
...
10
​
11
class SchemaCommands {
12
private final CommandRouter router;
13
private final Stage stage;
14
​
15
SchemaCommands(final Stage stage, final int routees) {
16
this.stage = stage;
17
this.router = CommandRouter.of(stage, Type.LoadBalancing, routees);
18
}
19
...
20
}
Copied!
The
SchemaCommands parent is instantiated with the Stage and the number of routees to be create for the router. The constructor creates a new CommandRouter that is the type used for LoadBalancing.Once the
SchemaCommands instance exists, it can be used to instantiate individual command instances. The first factory used is categorizeAs() that instantiates a CategorizeAs that is wrapped in a RoutableCommand.1
class SchemaCommands {
2
...
3
RoutableCommand<Schema,CategorizeAs,SchemaState> categorizeAs(
4
final SchemaId schemaId,
5
final Category category) {
6
​
7
final CategorizeAs categorizedAs = new CategorizeAs(category);
8
​
9
RoutableCommand<Schema,CategorizeAs,SchemaState> command =
10
RoutableCommand
11
.speaks(Schema.class)
12
.to(SchemaEntity.class)
13
.at(schemaId.value)
14
.createsWith(Definition.parameters(schemaId))
15
.named(Schema.nameFrom(schemaId))
16
.delivers(categorizedAs)
17
.answers(Completes.using(stage.scheduler()))
18
.handledBy(categorizedAs);
19
​
20
router.route(command);
21
​
22
return command;
23
}
24
...
25
}
Copied!
The
RoutableCommand generic type parameters are as follows:- 1.The
Pprotocol is theSchemadomain model interface. - 2.The
Ccommand type isCommandsubclassCategorizeAs. - 3.The A answer type is
SchemaState, which is the type used to hold and transfer theSchematype's immutable state data.
Note that the
SchemaCommands does not provide a factory method for the initial Schema type instance. That's because we use a factory method on the protocol type interface itself that's used to instantiate the initial Schema domain model object. The protocol commands other than the factory methods are provided.The parameters to the command are
SchemaId and Category. First the CategorizeAs concrete command type itself is instantiated with the two parameters. Next the instance of CategorizeAs is wrapped by a new RoutableCommand , and it is then routed. Finally the RoutableCommand is answered from the factory.The
RoutableCommand answer is used to receive the SchemaState instance when it arrives by way of the Completes<SchemaState>. The REST resource handler type SchemaResource initially received an HTTP PATCH request and used the SchemaCommands factory method categorizeAs() in order to create the RoutableCommand. Once the RoutableCommand is returned to the SchemaResource request handler, the request handler registers a function on the Completes<SchemaState> that will deliver the eventual outcome when it arrives.1
public class SchemaResource extends DynamicResourceHandler {
2
private final Grid grid;
3
private final SchemaCommands commands;
4
private final SchemaQueries queries;
5
​
6
public SchemaResource(final Grid grid) {
7
super(grid.world().stage());
8
this.grid = grid;
9
this.commands = new SchemaCommands(grid, 10);
10
this.queries = StorageProvider.instance().schemaQueries;
11
}
12
...
13
public Completes<Response> categorizeAs(final String organizationId, final String unitId, final String contextId, final String schemaId, final String category) {
14
return commands
15
.categorizeAs(SchemaId.existing(organizationId, unitId, contextId, schemaId), Category.valueOf(category)).answer()
16
.andThenTo(state -> Completes.withSuccess(Response.of(Ok, entityResponseOf(serialized(SchemaData.from(state))))));
17
}
18
...
19
}
Copied!
When the function is executed, the final outcomes is produced and in turn is put into a completes to be used by the XOOM HTTP server as a response to the client.
Dispatching the Command
The
CategorizeAs command type itself plays and important role beyond carrying a parameter payload. When the router is ready to delivery the command, it uses the command itself to perform the dispatching.1
public class SchemaResource extends DynamicResourceHandler {
2
...
3
private static class CategorizeAs extends Command implements CommandDispatcher<Schema,CategorizeAs,Completes<SchemaState>> {
4
private final Category category;
5
​
6
CategorizeAs(final Category category) {
7
this.category = category;
8
}
9
​
10
@Override
11
public void accept(final Schema protocol, final CategorizeAs command, final Completes<SchemaState> answer) {
12
protocol.categorizeAs(command.category).andThen(state -> answer.with(state));
13
}
14
}
15
...
16
}
Copied!
To actually deliver the
CategorizeAs command to its destination, the router uses the accept() on the CategorizeAs concrete CommandDispatcher, a Java functional interface, to do so. The accept() method sends the categorizeAs() message and parameters to the SchemaEntity actor through its registered protocol.Other Examples
​
​
​
Last modified 1yr ago