server/io.spine.server.commandbus/ExecutorCommandScheduler

ExecutorCommandScheduler

public class ExecutorCommandScheduler extends CommandScheduler

The command scheduler implementation which uses basic Java task scheduling features.

NOTE: please use another implementation in applications running under the Google App Engine.

Constructors

public void ExecutorCommandScheduler(ScheduledExecutorService executorService)

public void ExecutorCommandScheduler()

Functions

doSchedule

protected void doSchedule(Command command)

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

shutdown

public void shutdown()

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

Inherited functions

checkOpen

public void checkOpen()

Ensures that the object is open.

public void close()

By default, performs no action.

public abstract void close()

commandBus

protected CommandBus commandBus()

Obtains CommandBus associated with this scheduler.

filter

public abstract Optional<Ack> filter(E envelope)

public Optional<Ack> filter(CommandEnvelope envelope)

Accepts or rejects a passed message.

isOpen

public boolean isOpen()

Tells if the object is still open.

letPass

public Optional<Ack> letPass()

Lets the message pass the filter.

post

protected void post(Command command)

Delivers a scheduled command to a target.

reject

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.

schedule

public void schedule(Command command)

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

ExecutorCommandScheduler

See also

Constructors

Functions

Inherited functions