Package org.apache.storm.messaging
Interface IConnection
- All Superinterfaces:
AutoCloseable
- All Known Implementing Classes:
Client
,ConnectionWithStatus
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
close this connection.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 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:
close
in interfaceAutoCloseable
-