org.apache.storm.messaging

Class DeserializingConnectionCallback

java.lang.Object

org.apache.storm.messaging.DeserializingConnectionCallback

All Implemented Interfaces:

IConnectionCallback

public class DeserializingConnectionCallback
extends Object
implements IConnectionCallback

A class that is called when a TaskMessage arrives.

Constructor Summary

Constructors

Constructor and Description
DeserializingConnectionCallback(Map conf, GeneralTopologyContext context, clojure.lang.IFn callback)

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DeserializingConnectionCallback

public DeserializingConnectionCallback(Map conf,
                                       GeneralTopologyContext context,
                                       clojure.lang.IFn callback)

Method Detail

recv

public void recv(List<TaskMessage> batch)

Description copied from interface: IConnectionCallback

A batch of new messages have arrived to be processed

Specified by:

recv in interface IConnectionCallback

Parameters:

batch - the messages to be processed