Package org.apache.ignite.spi.discovery.tcp.messages

Class TcpDiscoveryCustomEventMessage

java.lang.Object

org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAbstractMessage

org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAbstractTraceableMessage

org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryCustomEventMessage

All Implemented Interfaces:

Serializable, TraceableMessage

Direct Known Subclasses:

TcpDiscoveryServerOnlyCustomEventMessage

@TcpDiscoveryRedirectToClient
@TcpDiscoveryEnsureDelivery
public class TcpDiscoveryCustomEventMessage
extends TcpDiscoveryAbstractTraceableMessage

Wrapped for custom message.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAbstractMessage

CHANGE_TOPOLOGY_FLAG_POS, CLIENT_ACK_FLAG_POS, CLIENT_FLAG_POS, CLIENT_RECON_SUCCESS_FLAG_POS, FORCE_FAIL_FLAG_POS, RESPONDED_FLAG_POS

Constructor Summary

Constructors

Constructor	Description
TcpDiscoveryCustomEventMessage(UUID creatorNodeId, @Nullable DiscoverySpiCustomMessage msg, @org.jetbrains.annotations.NotNull byte[] msgBytes)
TcpDiscoveryCustomEventMessage(TcpDiscoveryCustomEventMessage msg)	Copy constructor.

Method Summary

Modifier and Type	Method	Description
void	clearMessage()	Clear deserialized form of wrapped message.
boolean	equals(Object obj)
@Nullable DiscoverySpiCustomMessage	message(@NotNull Marshaller marsh, ClassLoader ldr)
void	message(@Nullable DiscoverySpiCustomMessage msg, @org.jetbrains.annotations.NotNull byte[] msgBytes)
byte[]	messageBytes()
String	toString()

Methods inherited from class org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAbstractTraceableMessage

readResolve, spanContainer

Methods inherited from class org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAbstractMessage

addFailedNode, client, client, creatorNodeId, failedNodes, failedNodes, force, force, getFlag, hashCode, highPriority, id, pendingIndex, pendingIndex, senderNodeId, senderNodeId, setFlag, topologyVersion, topologyVersion, traceLogLevel, verified, verifierNodeId, verify

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpDiscoveryCustomEventMessage

public TcpDiscoveryCustomEventMessage(UUID creatorNodeId,
                                      @Nullable
                                      @Nullable DiscoverySpiCustomMessage msg,
                                      @NotNull
                                      @org.jetbrains.annotations.NotNull byte[] msgBytes)

Parameters:

creatorNodeId - Creator node id.

msg - Message.

msgBytes - Serialized message.

TcpDiscoveryCustomEventMessage

public TcpDiscoveryCustomEventMessage(TcpDiscoveryCustomEventMessage msg)

Copy constructor.

Parameters:

msg - Message.

Method Detail

clearMessage

public void clearMessage()

Clear deserialized form of wrapped message.

messageBytes

public byte[] messageBytes()

Returns:

Serialized message.

message

public void message(@Nullable
                    @Nullable DiscoverySpiCustomMessage msg,
                    @NotNull
                    @org.jetbrains.annotations.NotNull byte[] msgBytes)

Parameters:

msg - Message.

msgBytes - Serialized message.

message

@Nullable
public @Nullable DiscoverySpiCustomMessage message(@NotNull
                                                   @NotNull Marshaller marsh,
                                                   ClassLoader ldr)
                                            throws Throwable

Parameters:

marsh - Marshaller.

ldr - Classloader.

Returns:

Deserialized message,

Throws:

Throwable - if unmarshal failed.

equals

public boolean equals(Object obj)

Overrides:

equals in class TcpDiscoveryAbstractMessage

toString

public String toString()

Overrides:

toString in class TcpDiscoveryAbstractMessage