CommandScheduler

public abstract class CommandScheduler implements BusFilter<E>, Closeable

Schedules commands delivering them to the target according to the scheduling options.

Constructors

protected void CommandScheduler()

public void close()

By default, performs no action.

Obtains CommandBus associated with this scheduler.

protected abstract void doSchedule(Command command)

Schedules a command and delivers it to the target according to the scheduling options set to a context.

Accepts or rejects a passed message.

public boolean isOpen()

Tells if the object is still open.

protected void post(Command command)

Delivers a scheduled command to a target.

public void schedule(Command command)

Schedules a command and delivers it to the target according to the scheduling options.

public void shutdown()

Initiates an orderly shutdown in which previously scheduled commands will be delivered later, but no new commands will be accepted.

public void checkOpen()

Ensures that the object is open.

public Optional<Ack> letPass()

Lets the message pass the filter.

public Optional<Ack> reject(E envelope)

Rejects the message with the OK status.

public Optional<Ack> reject(E envelope, ThrowableMessage cause)

Rejects the message with a rejection status.

public Optional<Ack> reject(E envelope, Error cause)

Rejects the message with an Error status.