protected abstract InstructionHandler<IN,OUT> |
AbstractIncomingInstructionStream.getHandler(IN msgIn) |
|
static InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction> |
ProcessorInstructions.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> |
ProcessorInstructions.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> |
ProcessorInstructions.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> |
ProcessorInstructions.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> |
ProcessorInstructions.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> |
ProcessorInstructions.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).
|