Package csw.command.client
Class SequencerCommandServiceImpl
- java.lang.Object
-
- csw.command.client.SequencerCommandServiceImpl
-
- All Implemented Interfaces:
csw.command.api.scaladsl.SequencerCommandService
public class SequencerCommandServiceImpl extends java.lang.Object implements csw.command.api.scaladsl.SequencerCommandService
Create a SequencerCommandService for sending commands to sequencer param: sequencerLocation the destination sequencer location to which sequence needs to be sent param: actorSystem required for sending sequence commands or querying the sequencer
-
-
Constructor Summary
Constructors Constructor Description SequencerCommandServiceImpl(AkkaLocation sequencerLocation, akka.actor.typed.ActorSystem<?> actorSystem)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description scala.concurrent.Future<CommandResponse.SubmitResponse>
query(Id runId)
scala.concurrent.Future<CommandResponse.SubmitResponse>
queryFinal(Id runId, akka.util.Timeout timeout)
scala.concurrent.Future<CommandResponse.SubmitResponse>
submit(Sequence sequence)
scala.concurrent.Future<CommandResponse.SubmitResponse>
submitAndWait(Sequence sequence, akka.util.Timeout timeout)
-
-
-
Constructor Detail
-
SequencerCommandServiceImpl
public SequencerCommandServiceImpl(AkkaLocation sequencerLocation, akka.actor.typed.ActorSystem<?> actorSystem)
-
-
Method Detail
-
query
public scala.concurrent.Future<CommandResponse.SubmitResponse> query(Id runId)
- Specified by:
query
in interfacecsw.command.api.scaladsl.SequencerCommandService
-
queryFinal
public scala.concurrent.Future<CommandResponse.SubmitResponse> queryFinal(Id runId, akka.util.Timeout timeout)
- Specified by:
queryFinal
in interfacecsw.command.api.scaladsl.SequencerCommandService
-
submit
public scala.concurrent.Future<CommandResponse.SubmitResponse> submit(Sequence sequence)
- Specified by:
submit
in interfacecsw.command.api.scaladsl.SequencerCommandService
-
submitAndWait
public scala.concurrent.Future<CommandResponse.SubmitResponse> submitAndWait(Sequence sequence, akka.util.Timeout timeout)
- Specified by:
submitAndWait
in interfacecsw.command.api.scaladsl.SequencerCommandService
-
-