Package org.apache.storm.messaging
Interface IConnectionCallback
- All Known Implementing Classes:
- DeserializingConnectionCallback
public interface IConnectionCallback
A class that is called when a TaskMessage arrives.
- 
Method SummaryModifier and TypeMethodDescriptionvoidrecv(List<TaskMessage> batch) A batch of new messages have arrived to be processed.
- 
Method Details- 
recvA batch of new messages have arrived to be processed.- Parameters:
- batch- the messages to be processed
 
 
-