server/io.spine.server.commandbus

Package-level declarations

This package provides classes and interfaces related to CommandBus and its configuration.

Types

Link copied to clipboard
public final class CommandBus extends UnicastBus<T, E, C, D>
Dispatches the incoming commands to the corresponding handler.
Link copied to clipboard
public interface CommandDispatcher implements UnicastDispatcher<C, E>
Delivers commands to their handlers.
Link copied to clipboard
public interface CommandDispatcherDelegate
A common interface for objects which need to dispatch the commands, but are unable to implement the CommandDispatcher.
Link copied to clipboard
public abstract class CommandException extends RuntimeException implements MessageError
Abstract base for exceptions related to commands.
Link copied to clipboard
public interface CommandFlowWatcher
A set of callbacks invoked when a command processing reaches a given point.
Link copied to clipboard
public final class CommandPostingException extends RuntimeException
Exception that is thrown when a command could not be posted to a CommandBus.
Link copied to clipboard
public abstract class CommandScheduler implements BusFilter<E>, Closeable
Schedules commands delivering them to the target according to the scheduling options.
Link copied to clipboard
public class DelegatingCommandDispatcher implements CommandDispatcher
A CommandDispatcher, that delegates the responsibilities to an aggregated delegate instance.
Link copied to clipboard
public class ExecutorCommandScheduler extends CommandScheduler
The command scheduler implementation which uses basic Java task scheduling features.
Link copied to clipboard
public class InvalidCommandException extends CommandException implements MessageInvalid
The exception for reporting invalid commands.
Link copied to clipboard
public class UnsupportedCommandException extends CommandException implements MessageUnhandled
Exception that is thrown when unsupported command is obtained or in case there is no class for given Protobuf command message.