Package org.axonframework.axonserver.connector.processor

Class EventProcessorControlService.AxonProcessorInstructionHandler

java.lang.Object

org.axonframework.axonserver.connector.processor.EventProcessorControlService.AxonProcessorInstructionHandler

All Implemented Interfaces:

io.axoniq.axonserver.connector.control.ProcessorInstructionHandler

Enclosing class:

EventProcessorControlService

protected static class EventProcessorControlService.AxonProcessorInstructionHandler
extends Object
implements io.axoniq.axonserver.connector.control.ProcessorInstructionHandler

Constructor Summary

Constructors

Constructor	Description
AxonProcessorInstructionHandler(EventProcessor processor, String name)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Boolean>	mergeSegment(int segmentId)
CompletableFuture<Void>	pauseProcessor()
CompletableFuture<Boolean>	releaseSegment(int segmentId)
CompletableFuture<Boolean>	splitSegment(int segmentId)
CompletableFuture<Void>	startProcessor()

Methods inherited from class java.lang.Object

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

Constructor Details

AxonProcessorInstructionHandler

public AxonProcessorInstructionHandler(EventProcessor processor,
 String name)

Method Details

releaseSegment

public CompletableFuture<Boolean> releaseSegment(int segmentId)

Specified by:

releaseSegment in interface io.axoniq.axonserver.connector.control.ProcessorInstructionHandler

splitSegment

public CompletableFuture<Boolean> splitSegment(int segmentId)

Specified by:

splitSegment in interface io.axoniq.axonserver.connector.control.ProcessorInstructionHandler

mergeSegment

public CompletableFuture<Boolean> mergeSegment(int segmentId)

Specified by:

mergeSegment in interface io.axoniq.axonserver.connector.control.ProcessorInstructionHandler

pauseProcessor

public CompletableFuture<Void> pauseProcessor()

Specified by:

pauseProcessor in interface io.axoniq.axonserver.connector.control.ProcessorInstructionHandler

startProcessor

public CompletableFuture<Void> startProcessor()

Specified by:

startProcessor in interface io.axoniq.axonserver.connector.control.ProcessorInstructionHandler