org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication

Interface HadoopMessageListener

public interface HadoopMessageListener

Hadoop communication message listener.

Method Summary

Modifier and Type	Method and Description
void	onConnectionLost(HadoopProcessDescriptor desc) Called when connection to remote process was lost.
void	onMessageReceived(HadoopProcessDescriptor desc, HadoopMessage msg)

Method Detail

onMessageReceived

void onMessageReceived(HadoopProcessDescriptor desc,
                       HadoopMessage msg)

Parameters:

desc - Process descriptor.

msg - Hadoop message.

onConnectionLost

void onConnectionLost(HadoopProcessDescriptor desc)

Called when connection to remote process was lost.

Parameters:

desc - Process descriptor.