Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.connector.impl

Class ProcessorInstructions

java.lang.Object

io.axoniq.axonserver.connector.impl.ProcessorInstructions

public abstract class ProcessorInstructions
extends Object

Utility class providing InstructionHandler instances for event processor instructions.

Method Summary

Modifier and Type	Method	Description
static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction>	mergeHandler(Map<String,ProcessorInstructionHandler> instructionHandlers)	Provides a InstructionHandler which handles a processor's merge request from AxonServer and sends it to the right client(s).
static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction>	pauseHandler(Map<String,ProcessorInstructionHandler> instructionHandlers)	Provides a InstructionHandler which handles a processor's pause request from AxonServer and sends it to the right client(s).
static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction>	releaseSegmentHandler(Map<String,ProcessorInstructionHandler> instructionHandlers)	Provides a InstructionHandler which handles a processor's release segment request from AxonServer and sends it to the right client(s).
static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction>	requestInfoHandler(Map<String,Supplier<EventProcessorInfo>> infoSuppliers)	Provides a InstructionHandler which handles a processor's information request from AxonServer and sends it to the right client(s).
static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction>	splitHandler(Map<String,ProcessorInstructionHandler> instructionHandlers)	Provides a InstructionHandler which handles a processor's split request from AxonServer and sends it to the right client(s).
static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction>	startHandler(Map<String,ProcessorInstructionHandler> instructionHandlers)	Provides a InstructionHandler which handles a processor's start request from AxonServer and sends it to the right client(s).

Methods inherited from class java.lang.Object

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

Method Detail

mergeHandler

public static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction> mergeHandler(Map<String,ProcessorInstructionHandler> instructionHandlers)

Provides a InstructionHandler which handles a processor's merge request from AxonServer and sends it to the right client(s).

Parameters:

instructionHandlers - the collection of instruction handler instances to retrieve the ProcessorInstructionHandler from to execute the actual ProcessorInstructionHandler.mergeSegment(int) operation

Returns:

the InstructionHandler to delegate the merge request with

splitHandler

public static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction> splitHandler(Map<String,ProcessorInstructionHandler> instructionHandlers)

Provides a InstructionHandler which handles a processor's split request from AxonServer and sends it to the right client(s).

Parameters:

instructionHandlers - the collection of instruction handler instances to retrieve the ProcessorInstructionHandler from to execute the actual ProcessorInstructionHandler.splitSegment(int) operation

Returns:

the InstructionHandler to delegate the split request with

startHandler

public static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction> startHandler(Map<String,ProcessorInstructionHandler> instructionHandlers)

Provides a InstructionHandler which handles a processor's start request from AxonServer and sends it to the right client(s).

Parameters:

instructionHandlers - the collection of instruction handler instances to retrieve the ProcessorInstructionHandler from to execute the actual ProcessorInstructionHandler.startProcessor() operation

Returns:

the InstructionHandler to delegate the start request with

pauseHandler

public static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction> pauseHandler(Map<String,ProcessorInstructionHandler> instructionHandlers)

Provides a InstructionHandler which handles a processor's pause request from AxonServer and sends it to the right client(s).

Parameters:

instructionHandlers - the collection of instruction handler instances to retrieve the ProcessorInstructionHandler from to execute the actual ProcessorInstructionHandler.pauseProcessor() operation

Returns:

the InstructionHandler to delegate the pause request with

releaseSegmentHandler

public static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction> releaseSegmentHandler(Map<String,ProcessorInstructionHandler> instructionHandlers)

Provides a InstructionHandler which handles a processor's release segment request from AxonServer and sends it to the right client(s).

Parameters:

instructionHandlers - the collection of instruction handler instances to retrieve the ProcessorInstructionHandler from to execute the actual ProcessorInstructionHandler.releaseSegment(int)} operation

Returns:

the InstructionHandler to delegate the release segment request with

requestInfoHandler

public static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction> requestInfoHandler(Map<String,Supplier<EventProcessorInfo>> infoSuppliers)

Provides a InstructionHandler which handles a processor's information request from AxonServer and sends it to the right client(s).

Parameters:

infoSuppliers - the collection of EventProcessorInfo supplier instances to retrieve the right instance to pull information from

Returns:

the InstructionHandler to delegate the processor information request with