org.apache.ignite.spi.communication.tcp.internal

Class TcpConnectionRequestDiscoveryMessage

java.lang.Object

org.apache.ignite.spi.communication.tcp.internal.TcpConnectionRequestDiscoveryMessage

All Implemented Interfaces:

Serializable, DiscoveryCustomMessage

public class TcpConnectionRequestDiscoveryMessage
extends Object
implements DiscoveryCustomMessage

Message is part of communication via discovery protocol. It is used when a node (say node A) cannot establish a communication connection to other node (node B) in topology due to firewall or network configuration and sends this message requesting inverse connection: node B receives request and opens communication connection to node A thus allowing both nodes to communicate to each other.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TcpConnectionRequestDiscoveryMessage(UUID receiverNodeId, int connIdx)

Method Summary

Modifier and Type	Method and Description
@Nullable DiscoveryCustomMessage	ackMessage() Called when custom message has been handled by all nodes.
int	connectionIndex()
DiscoCache	createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache) Creates new discovery cache if message caused topology version change.
IgniteUuid	id()
boolean	isMutable()
UUID	receiverNodeId()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

TcpConnectionRequestDiscoveryMessage

public TcpConnectionRequestDiscoveryMessage(UUID receiverNodeId,
                                            int connIdx)

Method Detail

id

public IgniteUuid id()

Specified by:

id in interface DiscoveryCustomMessage

Returns:

Unique custom message ID.

receiverNodeId

public UUID receiverNodeId()

connectionIndex

public int connectionIndex()

ackMessage

@Nullable
public @Nullable DiscoveryCustomMessage ackMessage()

Called when custom message has been handled by all nodes.

Specified by:

ackMessage in interface DiscoveryCustomMessage

Returns:

Ack message or null if ack is not required.

isMutable

public boolean isMutable()

Specified by:

isMutable in interface DiscoveryCustomMessage

Returns:

True if message can be modified during listener notification. Changes will be sent to next nodes.

createDiscoCache

public DiscoCache createDiscoCache(GridDiscoveryManager mgr,
                                   AffinityTopologyVersion topVer,
                                   DiscoCache discoCache)

Creates new discovery cache if message caused topology version change.

Specified by:

createDiscoCache in interface DiscoveryCustomMessage

Parameters:

mgr - Discovery manager.

topVer - New topology version.

discoCache - Current discovery cache.

Returns:

Reused discovery cache.

toString

public String toString()

Overrides:

toString in class Object