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

Packages that use IConnection

Package	Description
org.apache.storm.daemon.metrics
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.metrics

Method parameters in org.apache.storm.daemon.metrics with type arguments of type IConnection

Modifier and Type	Method and Description
static void	BuiltinMetricsUtil.registerIconnectionClientMetrics(Map<NodeInfo,IConnection> nodePortToSocket, Map<String,Object> topoConf, TopologyContext context)

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)