Uses of Interface
org.apache.storm.messaging.IConnection
Package
Description
-
Uses of IConnection in org.apache.storm.daemon.worker
Modifier and TypeMethodDescriptionstatic boolean
WorkerState.isConnectionReady
(IConnection connection) -
Uses of IConnection in org.apache.storm.messaging
Modifier and TypeMethodDescriptionIContext.bind
(String stormId, int port, IConnectionCallback cb, Supplier<Object> newConnectionResponse) This method establishes a server side connection.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
Modifier and TypeMethodDescriptionContext.bind
(String stormId, int port, IConnectionCallback cb, Supplier<Object> newConnectionResponse) Context.connect
(String stormId, String host, int port, AtomicBoolean[] remoteBpStatus) -
Uses of IConnection in org.apache.storm.messaging.netty
Modifier and TypeClassDescriptionclass
A Netty client for sending task messages to a remote destination (Netty server).Modifier and TypeMethodDescriptionContext.bind
(String stormId, int port, IConnectionCallback cb, Supplier<Object> newConnectionResponse) establish a server with a binding port.Context.connect
(String stormId, String host, int port, AtomicBoolean[] remoteBpStatus) establish a connection to a remote server.