Uses of Interface
org.apache.storm.messaging.IConnectionCallback
-
Packages that use IConnectionCallback Package Description org.apache.storm.messaging org.apache.storm.messaging.local org.apache.storm.messaging.netty -
-
Uses of IConnectionCallback in org.apache.storm.messaging
Classes in org.apache.storm.messaging that implement IConnectionCallback Modifier and Type Class Description class
DeserializingConnectionCallback
A class that is called when a TaskMessage arrives.Methods in org.apache.storm.messaging with parameters of type IConnectionCallback Modifier and Type Method Description IConnection
IContext. bind(String stormId, int port, IConnectionCallback cb, Supplier<Object> newConnectionResponse)
This method establishes a server side connection. -
Uses of IConnectionCallback in org.apache.storm.messaging.local
Methods in org.apache.storm.messaging.local with parameters of type IConnectionCallback Modifier and Type Method Description IConnection
Context. bind(String stormId, int port, IConnectionCallback cb, Supplier<Object> newConnectionResponse)
-
Uses of IConnectionCallback in org.apache.storm.messaging.netty
Methods in org.apache.storm.messaging.netty with parameters of type IConnectionCallback Modifier and Type Method Description IConnection
Context. bind(String stormId, int port, IConnectionCallback cb, Supplier<Object> newConnectionResponse)
establish a server with a binding port.
-