org.axonframework.commandhandling.distributed

Class ConsistentHash.ConsistentHashMember

java.lang.Object

org.axonframework.commandhandling.distributed.ConsistentHash.ConsistentHashMember

All Implemented Interfaces:

Member

Enclosing class:

ConsistentHash

public static class ConsistentHash.ConsistentHashMember
extends Object
implements Member

Member implementation used by a ConsistentHash registry.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
Predicate<? super CommandMessage<?>>	getCommandFilter() Returns this member's filter describing the commands it supports
<T> Optional<T>	getConnectionEndpoint(Class<T> protocol) Get the endpoint of this Member given a protocol.
int	hashCode()
Set<String>	hashes() Returns the hashes covered by the member.
boolean	local()
String	name() Returns the name of this Member.
int	segmentCount() Returns this member's segment count which relates to the relative load factor of the member.
void	suspect() Mark this member as suspect, i.e.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

name

public String name()

Description copied from interface: Member

Returns the name of this Member.

Specified by:

name in interface Member

Returns:

the member name

local

public boolean local()

Specified by:

local in interface Member

Returns:

True if the member is local. False if the member is remote or if this information is unknown.

suspect

public void suspect()

Description copied from interface: Member

Mark this member as suspect, i.e. suspected of being (temporarily) unavailable.

Specified by:

suspect in interface Member

segmentCount

public int segmentCount()

Returns this member's segment count which relates to the relative load factor of the member.

Returns:

the member's segment count

getCommandFilter

public Predicate<? super CommandMessage<?>> getCommandFilter()

Returns this member's filter describing the commands it supports

Returns:

the filter that describes this member's supported commands

hashes

public Set<String> hashes()

Returns the hashes covered by the member. If the hash of the routing key matches with one of the returned hashes and the member is capable of handling the command then it will be selected as a target for the command.

Returns:

the hashes covered by this member

getConnectionEndpoint

public <T> Optional<T> getConnectionEndpoint(Class<T> protocol)

Description copied from interface: Member

Get the endpoint of this Member given a protocol. Returns an empty optional if the protocol is not a supported endpoint of this member.

Specified by:

getConnectionEndpoint in interface Member

Type Parameters:

T - the protocol type

Parameters:

protocol - the expected

Returns:

the endpoint if this member supports the protocol. An empty optional otherwise.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object