Package csw.command.api.utils

Class CommandServiceExtension

java.lang.Object

csw.command.api.utils.CommandServiceExtension

public class CommandServiceExtension
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
CommandServiceExtension(csw.command.api.scaladsl.CommandService commandService, akka.actor.typed.ActorSystem<?> actorSystem)

Method Summary

Modifier and Type	Method	Description
akka.actor.typed.ActorSystem<?>	actorSystem()
scala.concurrent.Future<CommandResponse.MatchingResponse>	onewayAndMatch(ControlCommand controlCommand, StateMatcher stateMatcher)
scala.concurrent.Future<scala.collection.immutable.List<CommandResponse.SubmitResponse>>	submitAllAndWait(scala.collection.immutable.List<ControlCommand> submitCommands, akka.util.Timeout timeout)
scala.concurrent.Future<CommandResponse.SubmitResponse>	submitAndWait(ControlCommand controlCommand, akka.util.Timeout timeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

CommandServiceExtension

public CommandServiceExtension(csw.command.api.scaladsl.CommandService commandService,
                               akka.actor.typed.ActorSystem<?> actorSystem)

Method Detail

actorSystem

public akka.actor.typed.ActorSystem<?> actorSystem()

onewayAndMatch

public scala.concurrent.Future<CommandResponse.MatchingResponse> onewayAndMatch(ControlCommand controlCommand,
                                                                                StateMatcher stateMatcher)

submitAllAndWait

public scala.concurrent.Future<scala.collection.immutable.List<CommandResponse.SubmitResponse>> submitAllAndWait(scala.collection.immutable.List<ControlCommand> submitCommands,
                                                                                                                 akka.util.Timeout timeout)

submitAndWait

public scala.concurrent.Future<CommandResponse.SubmitResponse> submitAndWait(ControlCommand controlCommand,
                                                                             akka.util.Timeout timeout)