Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.event

Interface EventSchedulerGrpc.AsyncService

All Known Implementing Classes:

EventSchedulerGrpc.EventSchedulerImplBase

Enclosing class:

EventSchedulerGrpc

public static interface EventSchedulerGrpc.AsyncService

 Service to use AxonServer as a provider of an EventScheduler 
 

Method Summary

Modifier and Type	Method	Description
default void	cancelScheduledEvent(CancelScheduledEventRequest request, io.grpc.stub.StreamObserver<InstructionAck> responseObserver)	Cancel the publication of a scheduled event.
default void	rescheduleEvent(RescheduleEventRequest request, io.grpc.stub.StreamObserver<ScheduleToken> responseObserver)	Cancel a scheduled event and schedule another in its place.
default void	scheduleEvent(ScheduleEventRequest request, io.grpc.stub.StreamObserver<ScheduleToken> responseObserver)	Schedule the given event for publication at the given time}.

Method Detail

scheduleEvent

default void scheduleEvent(ScheduleEventRequest request,
                           io.grpc.stub.StreamObserver<ScheduleToken> responseObserver)

  Schedule the given event for publication at the given time}. The returned ScheduleToken can be used to cancel the planned publication.
 

rescheduleEvent

default void rescheduleEvent(RescheduleEventRequest request,
                             io.grpc.stub.StreamObserver<ScheduleToken> responseObserver)

  Cancel a scheduled event and schedule another in its place.
 

cancelScheduledEvent

default void cancelScheduledEvent(CancelScheduledEventRequest request,
                                  io.grpc.stub.StreamObserver<InstructionAck> responseObserver)

  Cancel the publication of a scheduled event. If the events has already been published, this method does nothing.