Uses of Interface
io.axoniq.axonserver.connector.Registration

Packages that use Registration

Package	Description
io.axoniq.axonserver.connector
io.axoniq.axonserver.connector.command
io.axoniq.axonserver.connector.command.impl
io.axoniq.axonserver.connector.control
io.axoniq.axonserver.connector.impl
io.axoniq.axonserver.connector.query
io.axoniq.axonserver.connector.query.impl

Uses of Registration in io.axoniq.axonserver.connector

Methods in io.axoniq.axonserver.connector that return Registration

Modifier and Type	Method	Description
default Registration	Registration.awaitAck(long timeout, TimeUnit unit)	Wait for the acknowledgement of the original instruction this Registration corresponds to.
default Registration	Registration.onAck(Runnable runnable)	Registers the given runnable to this Registration to be executed when the acknowledgement of this Registration is received.
default Registration	Registration.onAck(Consumer<Optional<Throwable>> action)	Registers the given runnable to this Registration to be executed when the acknowledgement of this Registration is received.

Uses of Registration in io.axoniq.axonserver.connector.command

Methods in io.axoniq.axonserver.connector.command that return Registration

Modifier and Type	Method	Description
Registration	CommandChannel.registerCommandHandler(Function<Command,CompletableFuture<CommandResponse>> handler, int loadFactor, String... commandNames)	Registers the given handler to handle incoming commands with given commandNames, using the given loadFactor.

Uses of Registration in io.axoniq.axonserver.connector.command.impl

Methods in io.axoniq.axonserver.connector.command.impl that return Registration

Modifier and Type	Method	Description
Registration	CommandChannelImpl.registerCommandHandler(Function<Command,CompletableFuture<CommandResponse>> handler, int loadFactor, String... commandNames)

Uses of Registration in io.axoniq.axonserver.connector.control

Methods in io.axoniq.axonserver.connector.control that return Registration

Modifier and Type	Method	Description
Registration	ControlChannel.registerEventProcessor(String processorName, Supplier<EventProcessorInfo> infoSupplier, ProcessorInstructionHandler instructionHandler)	Registers an Event Processor with AxonServer, allowing AxonServer to request status information and provide instructions for the Processor.
Registration	ControlChannel.registerInstructionHandler(PlatformOutboundInstruction.RequestCase type, InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction> handler)	Registers the given handler to handle a given type of instruction.
Registration	ControlChannel.registerTopologyChangeHandler(Consumer<TopologyChange> handler)	Registers a handler for changes in the topology of AxonServer.

Uses of Registration in io.axoniq.axonserver.connector.impl

Classes in io.axoniq.axonserver.connector.impl that implement Registration

Modifier and Type	Class	Description
class	AsyncRegistration	Asynchronous implementation of the Registration.
class	SyncRegistration	Synchronous implementation of the Registration.

Methods in io.axoniq.axonserver.connector.impl that return Registration

Modifier and Type	Method	Description
Registration	AsyncRegistration.awaitAck(long timeout, TimeUnit unit)
Registration	AsyncRegistration.onAck(Runnable runnable)
Registration	AsyncRegistration.onAck(Consumer<Optional<Throwable>> action)
Registration	ControlChannelImpl.registerEventProcessor(String processorName, Supplier<EventProcessorInfo> infoSupplier, ProcessorInstructionHandler instructionHandler)
Registration	ControlChannelImpl.registerInstructionHandler(PlatformOutboundInstruction.RequestCase type, InstructionHandler<PlatformOutboundInstruction,PlatformInboundInstruction> handler)
Registration	ControlChannelImpl.registerTopologyChangeHandler(Consumer<TopologyChange> handler)

Uses of Registration in io.axoniq.axonserver.connector.query

Methods in io.axoniq.axonserver.connector.query that return Registration

Modifier and Type	Method	Description
Registration	QueryChannel.registerQueryHandler(QueryHandler handler, QueryDefinition... queryTypes)	Registers the given handler to handle incoming queries defined through the given queryTypes.
default Registration	QueryHandler.registerSubscriptionQuery(SubscriptionQuery query, QueryHandler.UpdateHandler updateHandler)	Registers an incoming subscription query request, represented by given query, using given updateHandler to send updates when the projection for this query changes.

Uses of Registration in io.axoniq.axonserver.connector.query.impl

Methods in io.axoniq.axonserver.connector.query.impl that return Registration

Modifier and Type	Method	Description
Registration	QueryChannelImpl.registerQueryHandler(QueryHandler handler, QueryDefinition... queryDefinitions)