Package org.apache.ignite.spi.communication

Interface CommunicationListener<T extends Serializable>

All Superinterfaces:

EventListener

public interface CommunicationListener<T extends Serializable>
extends EventListener

Listener SPI notifies IO manager with.

CommunicationSpi should ignore very first 4 bytes received from sender node and pass the rest of the message to the listener.

Method Summary

Modifier and Type	Method	Description
void	onDisconnected(UUID nodeId)	Callback invoked when connection with remote node is lost.
void	onMessage(UUID nodeId, T msg, IgniteRunnable msgC)	NOTE: CommunicationSpi should ignore very first 4 bytes received from sender node and pass the rest of the received message to the listener.

Method Detail

onMessage

void onMessage(UUID nodeId,
               T msg,
               IgniteRunnable msgC)

NOTE: CommunicationSpi should ignore very first 4 bytes received from sender node and pass the rest of the received message to the listener.

Parameters:

nodeId - Node ID.

msg - Message.

msgC - Runnable to call when message processing finished.

onDisconnected

void onDisconnected(UUID nodeId)

Callback invoked when connection with remote node is lost.

Parameters:

nodeId - Node ID.