org.axonframework.commandhandling.distributed

Class SimpleMember<E>

java.lang.Object

org.axonframework.commandhandling.distributed.SimpleMember<E>

Type Parameters:

E - The type of the identifier of this entry in the set of nodes

All Implemented Interfaces:

Member

public class SimpleMember<E>
extends Object
implements Member

An endpoint in the network for a command handling service.

Field Summary

Fields

Modifier and Type	Field and Description
static Boolean	LOCAL_MEMBER Denotes that a SimpleMember is a representation of a Local Member, thus a representation of the instance itself.
static Boolean	REMOTE_MEMBER Denotes that a SimpleMember is a representation of a Remote Member.

Constructor Summary

Constructors

Constructor and Description
SimpleMember(String name, E endpoint, boolean local, Consumer<SimpleMember<E>> suspectHandler) Create the service member

Method Summary

Modifier and Type	Method and Description
E	endpoint() Returns this Member's endpoint.
boolean	equals(Object o)
<T> Optional<T>	getConnectionEndpoint(Class<T> protocol) Get the endpoint of this Member given a protocol.
int	hashCode()
boolean	local()
String	name() Returns the name of this 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

Field Detail

LOCAL_MEMBER

public static final Boolean LOCAL_MEMBER

Denotes that a SimpleMember is a representation of a Local Member, thus a representation of the instance itself.

REMOTE_MEMBER

public static final Boolean REMOTE_MEMBER

Denotes that a SimpleMember is a representation of a Remote Member.

Constructor Detail

SimpleMember

public SimpleMember(String name,
                    E endpoint,
                    boolean local,
                    Consumer<SimpleMember<E>> suspectHandler)

Create the service member

Parameters:

name - the member name

endpoint - The object describing the endpoint

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

suspectHandler - The operation to execute when this member is marked as a suspect

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

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.

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

endpoint

public E endpoint()

Returns this Member's endpoint.

Returns:

the endpoint of this member

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.

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