## Uses of Interface
org.apache.storm.messaging.IConnection

- Packages that use IConnection
  Package | Description
  --- | ---
  org.apache.storm.daemon.worker |
  org.apache.storm.messaging |
  org.apache.storm.messaging.local |
  org.apache.storm.messaging.netty |
  org.apache.storm.utils |

- - ### Uses of IConnection in org.apache.storm.daemon.worker

    Methods in org.apache.storm.daemon.worker that return IConnection
    Modifier and Type | Method and Description
    --- | ---
    `IConnection` | WorkerState.`getReceiver()`

    Methods in org.apache.storm.daemon.worker that return types with arguments of type IConnection
    Modifier and Type | Method and Description
    --- | ---
    `AtomicReference<Map<NodeInfo,IConnection>>` | WorkerState.`getCachedNodeToPortSocket()`

    Methods in org.apache.storm.daemon.worker with parameters of type IConnection
    Modifier and Type | Method and Description
    --- | ---
    `static boolean` | WorkerState.`isConnectionReady(IConnection connection)`

  - ### Uses of IConnection in org.apache.storm.messaging

    Classes in org.apache.storm.messaging that implement IConnection
    Modifier and Type | Class and Description
    --- | ---
    `class` | `ConnectionWithStatus`

    Methods in org.apache.storm.messaging that return IConnection
    Modifier and Type | Method and Description
    --- | ---
    `IConnection` | IContext.`bind(String stormId, int port, IConnectionCallback cb, Supplier<Object> newConnectionResponse)` This method establishes a server side connection.
    `IConnection` | IContext.`connect(String stormId, String host, int port, AtomicBoolean[] remoteBpStatus)` This method establish a client side connection to a remote server implementation should return a new connection every call.

  - ### Uses of IConnection in org.apache.storm.messaging.local

    Methods in org.apache.storm.messaging.local that return IConnection
    Modifier and Type | Method and Description
    --- | ---
    `IConnection` | Context.`bind(String stormId, int port, IConnectionCallback cb, Supplier<Object> newConnectionResponse)`
    `IConnection` | Context.`connect(String stormId, String host, int port, AtomicBoolean[] remoteBpStatus)`

  - ### Uses of IConnection in org.apache.storm.messaging.netty

    Classes in org.apache.storm.messaging.netty that implement IConnection
    Modifier and Type | Class and Description
    --- | ---
    `class` | `Client` A Netty client for sending task messages to a remote destination (Netty server).

    Methods in org.apache.storm.messaging.netty that return IConnection
    Modifier and Type | Method and Description
    --- | ---
    `IConnection` | Context.`bind(String stormId, int port, IConnectionCallback cb, Supplier<Object> newConnectionResponse)` establish a server with a binding port.
    `IConnection` | Context.`connect(String stormId, String host, int port, AtomicBoolean[] remoteBpStatus)` establish a connection to a remote server.

  - ### Uses of IConnection in org.apache.storm.utils

    Method parameters in org.apache.storm.utils with type arguments of type IConnection
    Modifier and Type | Method and Description
    --- | ---
    `void` | TransferDrainer.`send(Map<Integer,NodeInfo> taskToNode, Map<NodeInfo,IConnection> connections)`

Copyright © 2021 The Apache Software Foundation. All rights reserved.