org.apache.storm.messaging

Interface IConnectionCallback

All Known Implementing Classes:

DeserializingConnectionCallback

public interface IConnectionCallback

A class that is called when a TaskMessage arrives.

Method Summary

Modifier and Type	Method and Description
void	recv(List<TaskMessage> batch) A batch of new messages have arrived to be processed

Method Detail

recv

void recv(List<TaskMessage> batch)

A batch of new messages have arrived to be processed

Parameters:

batch - the messages to be processed