Package org.apache.storm.messaging
Interface IConnection
- All Superinterfaces:
AutoCloseable
- All Known Implementing Classes:
Client,ConnectionWithStatus
-
Method Summary
Modifier and TypeMethodDescriptionvoidclose()close this connection.getLoad(Collection<Integer> tasks) Get the current load for the given tasks.intgetPort()Get the port for this connection.voidsend(Iterator<TaskMessage> msgs) send batch messages.voidsendBackPressureStatus(BackPressureStatus bpStatus) Sends the back pressure metrics to all downstream connections.voidsendLoadMetrics(Map<Integer, Double> taskToLoad) Send load metrics to all downstream connections.
-
Method Details
-
sendLoadMetrics
Send load metrics to all downstream connections.- Parameters:
taskToLoad- a map from the task id to the load for that task.
-
sendBackPressureStatus
Sends the back pressure metrics to all downstream connections. -
send
send batch messages. -
getLoad
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:
closein interfaceAutoCloseable
-