Package org.axonframework.axonserver.connector

Class TopologyChange

java.lang.Object

org.axonframework.axonserver.connector.TopologyChange

public class TopologyChange
extends Object

Object representing a topology change at Axon Server.

Topology changes can be acted upon by registering a TopologyChangeListener.

Since:

4.12.0

Author:

Steven van Beelen

See Also:

• TopologyChangeListener

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TopologyChange.HandlerSubscription	The handler subscription of a TopologyChange.
static enum	TopologyChange.Type	The enumeration referencing the possible TopologyChange types.

Constructor Summary

Constructors

Constructor	Description
TopologyChange(io.axoniq.axonserver.grpc.control.TopologyChange change)	Constructs a TopologyChange based on the given gRPC change.
TopologyChange(TopologyChange.Type type, String context, String clientId, String clientStreamId, String componentName, TopologyChange.HandlerSubscription handlerSubscription)	Constructs a TopologyChange based on the give type, context, clientId, clientStreamId, componentName, and handler.

Method Summary

Modifier and Type	Method	Description
String	clientId()	Returns the client identifier for which a TopologyChange occurred.
String	clientStreamId()	Returns the client stream identifier for which a TopologyChange occurred.
String	componentName()	Returns the component name for which a TopologyChange occurred.
String	context()	Returns the context for which a TopologyChange occurred.
boolean	equals(Object o)
TopologyChange.HandlerSubscription	handler()	Returns the HandlerSubscription for which a TopologyChange occurred.
int	hashCode()
String	toString()
TopologyChange.Type	type()	Returns the Type of the TopologyChange.

Methods inherited from class java.lang.Object

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

Constructor Details

TopologyChange

public TopologyChange(TopologyChange.Type type,
 String context,
 String clientId,
 String clientStreamId,
 String componentName,
 TopologyChange.HandlerSubscription handlerSubscription)

Constructs a TopologyChange based on the give type, context, clientId, clientStreamId, componentName, and handler.

Parameters:

type - The type of the TopologyChange.

context - The context for which a TopologyChange occurred.

clientId - The client identifier for which a TopologyChange occurred.

clientStreamId - The client stream identifier for which a TopologyChange occurred.

componentName - The component name for which a TopologyChange occurred.

handlerSubscription - The TopologyChange.HandlerSubscription for which a TopologyChange occurred. Should be null for the Type RESET.

TopologyChange

public TopologyChange(io.axoniq.axonserver.grpc.control.TopologyChange change)

Constructs a TopologyChange based on the given gRPC change.

Parameters:

change - The gRPC TopologyChange to construct an Axon Framework TopologyChange from.

Method Details

type

public TopologyChange.Type type()

Returns the Type of the TopologyChange.

Returns:

The Type of the TopologyChange.

context

public String context()

Returns the context for which a TopologyChange occurred.

Returns:

The context for which a TopologyChange occurred.

clientId

public String clientId()

Returns the client identifier for which a TopologyChange occurred.

Returns:

The client identifier for which a TopologyChange occurred.

clientStreamId

public String clientStreamId()

Returns the client stream identifier for which a TopologyChange occurred.

Returns:

The client stream identifier for which a TopologyChange occurred.

componentName

public String componentName()

Returns the component name for which a TopologyChange occurred.

Returns:

The component name for which a TopologyChange occurred.

handler

public TopologyChange.HandlerSubscription handler()

Returns the HandlerSubscription for which a TopologyChange occurred.

Is null when type() returns TopologyChange.Type.RESET.

Returns:

The HandlerSubscription for which a TopologyChange occurred.

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