org.apache.storm.messaging

Interface IConnection

All Known Implementing Classes:

Client, ConnectionWithStatus

public interface IConnection

Method Summary

Modifier and Type	Method and Description
void	close() close this connection
Map<Integer,Load>	getLoad(Collection<Integer> tasks) Get the current load for the given tasks
void	registerRecv(IConnectionCallback cb) Register a callback to be notified when data is ready to be processed.
void	send(int taskId, byte[] payload) send a message with taskId and payload
void	send(Iterator<TaskMessage> msgs) send batch messages
void	sendLoadMetrics(Map<Integer,Double> taskToLoad) Send load metrics to all downstream connections.

Method Detail

registerRecv

void registerRecv(IConnectionCallback cb)

Register a callback to be notified when data is ready to be processed.

Parameters:

cb - the callback to process the messages.

sendLoadMetrics

void sendLoadMetrics(Map<Integer,Double> taskToLoad)

Send load metrics to all downstream connections.

Parameters:

taskToLoad - a map from the task id to the load for that task.

send

void send(int taskId,
          byte[] payload)

send a message with taskId and payload

Parameters:

taskId - task ID

payload -

send

void send(Iterator<TaskMessage> msgs)

send batch messages

Parameters:

msgs -

getLoad

Map<Integer,Load> getLoad(Collection<Integer> tasks)

Get the current load for the given tasks

Parameters:

tasks - the tasks to look for.

Returns:

a Load for each of the tasks it knows about.

close

void close()

close this connection