org.apache.storm.messaging

Interface IConnection

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

Client, ConnectionWithStatus

public interface IConnection
extends AutoCloseable

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.
int	getPort() Get the port for this connection.
void	send(Iterator<TaskMessage> msgs) send batch messages.
void	sendBackPressureStatus(BackPressureStatus bpStatus) Sends the back pressure metrics to all downstream connections.
void	sendLoadMetrics(Map<Integer,Double> taskToLoad) Send load metrics to all downstream connections.

Method Detail

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.

sendBackPressureStatus

void sendBackPressureStatus(BackPressureStatus bpStatus)

Sends the back pressure metrics to all downstream connections.

send

void send(Iterator<TaskMessage> msgs)

send batch messages.

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.

getPort

int getPort()

Get the port for this connection.

Returns:

The port this connection is using

close

void close()

close this connection.

Specified by:

close in interface AutoCloseable