Uses of Record Class
io.axoniq.framework.springcloud.routing.Member
Packages that use Member
Package
Description
The command side of the Spring Cloud connector: the connector distributing commands, and the HTTP transport carrying
them between members of the cluster.
The query side of the Spring Cloud connector: the connector distributing queries and subscription queries, and the
HTTP transport carrying them between members of the cluster.
Routing primitives for the Spring Cloud connector: the cluster
members, their capabilities, and the ConsistentHash ring that picks one for a given routing key.The parts of the Spring Cloud connector that the command side and the query side both rely on.
-
Uses of Member in io.axoniq.framework.springcloud.command
Methods in io.axoniq.framework.springcloud.command with parameters of type MemberModifier and TypeMethodDescriptionCompletableFuture<@Nullable CommandResultMessage> HttpRemoteCommandDispatcher.dispatch(Member member, CommandMessage command) CompletableFuture<@Nullable CommandResultMessage> RemoteCommandDispatcher.dispatch(Member member, CommandMessage command) Sends the givencommandto the givenmemberand completes with the outcome of handling it there. -
Uses of Member in io.axoniq.framework.springcloud.query
Methods in io.axoniq.framework.springcloud.query with parameters of type MemberModifier and TypeMethodDescriptionHttpRemoteQueryDispatcher.dispatch(Member member, QueryMessage query) RemoteQueryDispatcher.dispatch(Member member, QueryMessage query) Sends the givenqueryto the givenmember, reporting the responses it streams back.HttpRemoteQueryDispatcher.openSubscriptionQueryUpdateStream(Member member, QueryMessage query, int updateBufferSize, RemoteQueryDispatcher.SubscriptionListener listener) RemoteQueryDispatcher.openSubscriptionQueryUpdateStream(Member member, QueryMessage query, int updateBufferSize, RemoteQueryDispatcher.SubscriptionListener listener) Opens the stream of updates the givenqueryproduces on the givenmember. -
Uses of Member in io.axoniq.framework.springcloud.routing
Methods in io.axoniq.framework.springcloud.routing that return MemberModifier and TypeMethodDescriptionstatic MemberMember.localMember(String name) Constructs the localMemberrepresenting the application it is constructed in.Methods in io.axoniq.framework.springcloud.routing that return types with arguments of type MemberModifier and TypeMethodDescriptionConsistentHash.memberFor(String routingKey, QualifiedName commandName) Resolves theMemberthat should handle a command of the givencommandNamecarrying the givenroutingKey.ConsistentHash.members()Returns everyMemberregistered with this ring, including those claiming no ring positions.ConsistentHash.queryHandlers(QualifiedName queryName) Methods in io.axoniq.framework.springcloud.routing with parameters of type MemberModifier and TypeMethodDescriptionConsistentHash.capabilitiesOf(Member member) Returns theMemberCapabilitiesthe givenmemberis registered under.ConsistentHash.with(Member member, MemberCapabilities capabilities) Returns aConsistentHashwith the givenmemberregistered under the givencapabilities, replacing any earlier registration of a member with the samename.Returns aConsistentHashwithout the givenmember.Method parameters in io.axoniq.framework.springcloud.routing with type arguments of type MemberModifier and TypeMethodDescriptionConsistentHash.withOnly(Map<Member, MemberCapabilities> memberships) Returns aConsistentHashholding exactly the givenmemberships, hashed with this ring's hash function.