org.axonframework.quickstart

Class RunDistributedCommandBus

java.lang.Object

org.axonframework.quickstart.RunDistributedCommandBus

public class RunDistributedCommandBus
extends Object

This runner demonstrates the basic capabilities of the distributed command bus. It uses the default routing strategy based on annotations. JGroups is used to connect the multiple jvm instances. Two very basic logging command handlers are used to print the received commands. Each line starts with a number counting the amount of commands handled by the instance of the command handler.

When starting the runner two parameters are asked. The load factor and the amount of times to send the commands.

Author:

Jettro Coenradie

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RunDistributedCommandBus.ToDoLoggingCommandHandler

Constructor Summary

Constructors

Constructor and Description
RunDistributedCommandBus()

Method Summary

Methods

Modifier and Type	Method and Description
static Integer	determineLoadFactor()
static Integer	determineNumberOfCommandLoops()
static void	main(String[] args)
static Integer	readNumberFromCommandlinePlusDefault(String message, int defaultValue)

Methods inherited from class java.lang.Object

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

Constructor Detail

RunDistributedCommandBus

public RunDistributedCommandBus()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

determineNumberOfCommandLoops

public static Integer determineNumberOfCommandLoops()

determineLoadFactor

public static Integer determineLoadFactor()

readNumberFromCommandlinePlusDefault

public static Integer readNumberFromCommandlinePlusDefault(String message,
                                           int defaultValue)