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.TcpDiscoveryCustomEventMessage

All Implemented Interfaces:

Serializable

@TcpDiscoveryRedirectToClient
@TcpDiscoveryEnsureDelivery
public class TcpDiscoveryCustomEventMessage
extends TcpDiscoveryAbstractMessage

Wrapped for custom message.

See Also:

Serialized Form

Field Summary

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

CLIENT_ACK_FLAG_POS, CLIENT_FLAG_POS, CLIENT_RECON_SUCCESS_FLAG_POS, RESPONDED_FLAG_POS

Constructor Summary

Constructors

Constructor and Description
TcpDiscoveryCustomEventMessage(UUID creatorNodeId, DiscoverySpiCustomMessage msg, byte[] msgBytes)

Method Summary

Methods

Modifier and Type	Method and Description
void	message(DiscoverySpiCustomMessage msg, byte[] msgBytes)
DiscoverySpiCustomMessage	message(Marshaller marsh)
byte[]	messageBytes()
String	toString()

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

client, client, creatorNodeId, equals, getFlag, hashCode, highPriority, id, pendingIndex, pendingIndex, senderNodeId, senderNodeId, setFlag, topologyVersion, topologyVersion, 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
                              DiscoverySpiCustomMessage msg,
                              @NotNull
                              byte[] msgBytes)

Parameters:

creatorNodeId - Creator node id.

msg - Message.

msgBytes - Serialized message.

Method Detail

messageBytes

public byte[] messageBytes()

Returns:

Serialized message.

message

public void message(@Nullable
           DiscoverySpiCustomMessage msg,
           @NotNull
           byte[] msgBytes)

Parameters:

msg - Message.

msgBytes - Serialized message.

message

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

Returns:

Deserialized message,

Throws:

Throwable - if unmarshal failed.

toString

public String toString()

Overrides:

toString in class TcpDiscoveryAbstractMessage