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 and Description
AxonProcessorInstructionHandler(EventProcessor processor, String name)

Method Summary

Modifier and Type	Method and 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 Detail

AxonProcessorInstructionHandler

public AxonProcessorInstructionHandler(EventProcessor processor,
                                       String name)

Method Detail

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