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 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 Details

    • SequencerCommandServiceImpl

      public SequencerCommandServiceImpl(AkkaLocation sequencerLocation, akka.actor.typed.ActorSystem<?> actorSystem)

  • Method Details

    • query

      public scala.concurrent.Future<CommandResponse.SubmitResponse> query(Id runId)
      Specified by:
      query in interface csw.command.api.scaladsl.SequencerCommandService

    • queryFinal

      public scala.concurrent.Future<CommandResponse.SubmitResponse> queryFinal(Id runId, akka.util.Timeout timeout)
      Specified by:
      queryFinal in interface csw.command.api.scaladsl.SequencerCommandService

    • submit

      public scala.concurrent.Future<CommandResponse.SubmitResponse> submit(Sequence sequence)
      Specified by:
      submit in interface csw.command.api.scaladsl.SequencerCommandService

    • submitAndWait

      public scala.concurrent.Future<CommandResponse.SubmitResponse> submitAndWait(Sequence sequence, akka.util.Timeout timeout)
      Specified by:
      submitAndWait in interface csw.command.api.scaladsl.SequencerCommandService