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 -
-
Uses of IConnection in org.apache.storm.daemon.worker
Methods in org.apache.storm.daemon.worker that return IConnection Modifier and Type Method Description IConnectionWorkerState. getReceiver()Methods in org.apache.storm.daemon.worker that return types with arguments of type IConnection Modifier and Type Method Description AtomicReference<Map<NodeInfo,IConnection>>WorkerState. getCachedNodeToPortSocket()Methods in org.apache.storm.daemon.worker with parameters of type IConnection Modifier and Type Method Description static booleanWorkerState. isConnectionReady(IConnection connection) -
Uses of IConnection in org.apache.storm.messaging
Classes in org.apache.storm.messaging that implement IConnection Modifier and Type Class Description classConnectionWithStatusMethods in org.apache.storm.messaging that return IConnection Modifier and Type Method Description IConnectionIContext. bind(String stormId, int port, IConnectionCallback cb, Supplier<Object> newConnectionResponse)This method establishes a server side connection.IConnectionIContext. 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 Description IConnectionContext. bind(String stormId, int port, IConnectionCallback cb, Supplier<Object> newConnectionResponse)IConnectionContext. 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 Description classClientA 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 Description IConnectionContext. bind(String stormId, int port, IConnectionCallback cb, Supplier<Object> newConnectionResponse)establish a server with a binding port.IConnectionContext. connect(String stormId, String host, int port, AtomicBoolean[] remoteBpStatus)establish a connection to a remote server.
-