Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.event.dcb

Interface DcbEventSchedulerGrpc.AsyncService

All Known Implementing Classes:

DcbEventSchedulerGrpc.DcbEventSchedulerImplBase

Enclosing class:

DcbEventSchedulerGrpc

public static interface DcbEventSchedulerGrpc.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)	Reschedule a scheduled event and optionally replace it by a new event.
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 reschedule or cancel the planned publication.
 

rescheduleEvent

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

  Reschedule a scheduled event and optionally replace it by a new event.
 

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.