Package org.apache.storm.messaging
Interface IConnection
- All Superinterfaces:
- AutoCloseable
- All Known Implementing Classes:
- Client,- ConnectionWithStatus
- 
Method SummaryModifier 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- 
sendLoadMetricsSend load metrics to all downstream connections.- Parameters:
- taskToLoad- a map from the task id to the load for that task.
 
- 
sendBackPressureStatusSends the back pressure metrics to all downstream connections.
- 
sendsend batch messages.
- 
getLoadGet 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.
 
- 
getPortint getPort()Get the port for this connection.- Returns:
- The port this connection is using
 
- 
closevoid close()close this connection.- Specified by:
- closein interface- AutoCloseable
 
 
-