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 Summary

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

  • Method Details

    • recv

      void recv(List<TaskMessage> batch)
      A batch of new messages have arrived to be processed.
      Parameters:
      batch - the messages to be processed